Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Plain View
HBase >> mail # user >> BigDecimalColumnInterpreter


+
Julian Wissmann 2012-09-05, 16:17
+
Ted Yu 2012-09-05, 16:22
+
Julian Wissmann 2012-09-05, 19:07
+
Ted Yu 2012-09-05, 19:22
+
Julian Wissmann 2012-09-05, 19:49
+
Ted Yu 2012-09-05, 20:04
+
Julian Wissmann 2012-09-05, 20:30
+
anil gupta 2012-09-05, 21:04
+
anil gupta 2012-09-05, 21:27
+
Julian Wissmann 2012-09-06, 09:28
+
anil gupta 2012-09-06, 17:19
Copy link to this message
-
Re: BigDecimalColumnInterpreter
I am using HBase0.92.1. Which version you are using?
On Thu, Sep 6, 2012 at 10:19 AM, anil gupta <[EMAIL PROTECTED]> wrote:

> Hi Julian,
>
> You need to add the column qualifier explicitly in the scanner. You have
> only added the column family in the scanner.
> I am also assuming that you are writing a ByteArray of BigDecimal object
> as value of these cells in HBase. Is that right?
>
> Thanks,
> Anil
>
>
> On Thu, Sep 6, 2012 at 2:28 AM, Julian Wissmann <[EMAIL PROTECTED]>wrote:
>
>> Hi, anil,
>>
>> I presume you mean something like this:
>>         Scan scan = new Scan(_start, _end);
>>         scan.addFamily(family.getBytes());
>>         final ColumnInterpreter<BigDecimal, BigDecimal> ci = new
>> mypackage.BigDecimalColumnInterpreter();
>>         AggregationClient ag = new org.apache.hadoop.hbase.
>> client.coprocessor.AggregationClient(config);
>>         BigDecimal sum = ag.sum(Bytes.toBytes(tableName), new
>> BigDecimalColumnInterpreter(), scan);
>>
>>
>> When I call this,with the Endpoint in place and loaded as a jar, I get the
>> above error.
>> When I call it without the endpoint loaded as coprocessor, though, I get
>> this:
>>
>> java.util.concurrent.ExecutionException:
>> org.apache.hadoop.hbase.client.RetriesExhaustedException: Failed after
>> attempts=10, exceptions:
>> Thu Sep 06 11:07:39 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:40 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:41 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:42 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:44 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:46 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:50 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:54 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:08:02 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:08:18 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>>
>> at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:252)
>> at java.util.concurrent.FutureTask.get(FutureTask.java:111)
>> at
>>
>> org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.processExecs(HConnectionManager.java:1434)
>> at org.apache.hadoop.hbase.client.HTable.coprocessorExec(HTable.java:1263)
>> at
>>
>> org.apache.hadoop.hbase.client.coprocessor.AggregationClient.sum(AggregationClient.java:259)
>> at
>>
>> helpers.HbaseReaderBigDecimal.getWeeksumSCAN(HbaseReaderBigDecimal.java:355)
>> at helpers.HbaseReaderBigDecimal.main(HbaseReaderBigDecimal.java:76)
>> Caused by: org.apache.hadoop.hbase.client.RetriesExhaustedException:
>> Failed
>> after attempts=10, exceptions:
>> Thu Sep 06 11:07:39 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields

Thanks & Regards,
Anil Gupta
+
Julian Wissmann 2012-09-06, 18:43
+
anil gupta 2012-09-06, 19:22
+
Julian Wissmann 2012-09-10, 16:36
+
anil gupta 2012-09-10, 18:22
+
Julian Wissmann 2012-09-12, 16:27
+
Ted Yu 2012-09-12, 16:45
+
Julian Wissmann 2012-09-12, 19:56
+
anil gupta 2012-09-14, 07:56
+
anil gupta 2012-09-14, 19:27
+
anil gupta 2012-09-14, 22:17
+
Ted Yu 2012-09-15, 14:56
+
anil gupta 2012-09-15, 15:26
+
Julian Wissmann 2012-10-03, 16:26