hbase-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yuzhih...@gmail.com
Subject Re: Coprocessor POC
Date Sun, 29 Jul 2012 21:54:28 GMT
Can you use 0.94 for your client jar ?

Please show us the NullPointerException stack. 

Thanks



On Jul 29, 2012, at 2:49 PM, Cyril Scetbon <cyril.scetbon@free.fr> wrote:

> Hi,
> 
> I'm testing AggregationClient functions to check if we could use coprocessors for mathematical
functions.
> 
> The code I use is the following :
> 
> package coreprocessor;
> 
> import org.apache.hadoop.conf.Configuration;
> import org.apache.hadoop.hbase.HBaseConfiguration;
> import org.apache.hadoop.hbase.client.Scan;
> import org.apache.hadoop.hbase.client.coprocessor.AggregationClient;
> import org.apache.hadoop.hbase.util.Bytes;
> 
> public class AggregationClientTest {
> 
>   private static final byte[] TABLE_NAME = Bytes.toBytes("ise");
>   private static final byte[] CF = Bytes.toBytes("core");
> 
>   public static void main(String[] args) throws Throwable {
> 
>       Configuration configuration = HBaseConfiguration.create();
> 
>       configuration.setLong("hbase.client.scanner.caching", 1000);
>       AggregationClient aggregationClient = new AggregationClient(
>               configuration);
>       Scan scan = new Scan();
>       scan.addColumn(CF, Bytes.toBytes("value"));
>       System.out.println("row count is " + aggregationClient.rowCount(TABLE_NAME, null,
scan));
>       System.out.println("avg is " + aggregationClient.avg(TABLE_NAME, null, scan));
>       System.out.println("sum is " + aggregationClient.sum(TABLE_NAME, null, scan));
>   }
> }
> 
> The only one working is the rowCount function. For others I get a NPE error !
> I've checked that my table use only Long values for the column on which I work, and I've
only one row in my table :
> 
> ROW                                                  COLUMN+CELL                    
                                                                                         
                             
> id-cyr1                                             column=core:value, timestamp=1343596419845,
value=\x00\x00\x00\x00\x00\x00\x00\x0A                                                   
                 
> 
> The only thing I can add is that my hbase server's version is 0.94.0 and that I use version
0.92.0 of the hbase jar
> 
> any idea why it doesn't work ?
> 
> thanks 
> Cyril SCETBON
> 

Mime
View raw message