Mailing-List: contact user-help@hbase.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@hbase.apache.org
Received-SPF: pass (athena.apache.org: domain of yuzhihong@gmail.com
 designates 209.85.160.41 as permitted sender)
References: <1B2099D3-E07B-40EC-BB9D-C4B4D15E9EF2@free.fr>
In-Reply-To: <1B2099D3-E07B-40EC-BB9D-C4B4D15E9EF2@free.fr>
Mime-Version: 1.0 (1.0)
Content-Transfer-Encoding: quoted-printable
Content-Type: text/plain;
	charset=us-ascii
Message-Id: <9D846EB6-3E22-4137-9F5C-1DF63B749502@gmail.com>
Cc: "user@hbase.apache.org" <user@hbase.apache.org>
From: yuzhihong@gmail.com
Subject: Re: Coprocessor POC
Date: Sun, 29 Jul 2012 14:54:28 -0700
To: "user@hbase.apache.org" <user@hbase.apache.org>

Can you use 0.94 for your client jar ?

Please show us the NullPointerException stack.=20

Thanks


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

> Hi,
>=20
> I'm testing AggregationClient functions to check if we could use coprocess=
ors for mathematical functions.
>=20
> The code I use is the following :
>=20
> package coreprocessor;
>=20
> 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;
>=20
> public class AggregationClientTest {
>=20
>   private static final byte[] TABLE_NAME =3D Bytes.toBytes("ise");
>   private static final byte[] CF =3D Bytes.toBytes("core");
>=20
>   public static void main(String[] args) throws Throwable {
>=20
>       Configuration configuration =3D HBaseConfiguration.create();
>=20
>       configuration.setLong("hbase.client.scanner.caching", 1000);
>       AggregationClient aggregationClient =3D new AggregationClient(
>               configuration);
>       Scan scan =3D new Scan();
>       scan.addColumn(CF, Bytes.toBytes("value"));
>       System.out.println("row count is " + aggregationClient.rowCount(TABL=
E_NAME, null, scan));
>       System.out.println("avg is " + aggregationClient.avg(TABLE_NAME, nul=
l, scan));
>       System.out.println("sum is " + aggregationClient.sum(TABLE_NAME, nul=
l, scan));
>   }
> }
>=20
> The only one working is the rowCount function. For others I get a NPE erro=
r !
> I've checked that my table use only Long values for the column on which I w=
ork, and I've only one row in my table :
>=20
> ROW                                                  COLUMN+CELL          =
                                                                            =
                                                     =20
> id-cyr1                                             column=3Dcore:value, t=
imestamp=3D1343596419845, value=3D\x00\x00\x00\x00\x00\x00\x00\x0A          =
                                                          =20
>=20
> The only thing I can add is that my hbase server's version is 0.94.0 and t=
hat I use version 0.92.0 of the hbase jar
>=20
> any idea why it doesn't work ?
>=20
> thanks=20
> Cyril SCETBON
>=20