Thanks Yu. I have added below coprocessor to my table. And tried to invoke
coprocessor using java client. But fails with below error. But I could see
coprocessor in describe table output.
Caused by:
org.apache.hadoop.hbase.ipc.RemoteWithExtrasException(org.apache.hadoop.hbase.exceptions.UnknownProtocolException):
org.apache.hadoop.hbase.exceptions.UnknownProtocolException: No registered
coprocessor service found for name AggregateService in region
test3,,1397469869214.c73698dce0d5b91d29d42a9f9e194965.
at
org.apache.hadoop.hbase.regionserver.HRegion.execService(HRegion.java:5070)
>From describe table:
----------------------------------
test3', {TABLE_ATTRIBUTES => {coprocessor$1 =>
'hdfs://xxxxxxx.com:8020/user/yyyy/zzzz/hbase-server-0.98.1-hadoop2.jar|org.apache.hadoop.hbase.coprocessor.AggregateImplementation||'},
{NAME => 'cf'
Thanks,
Chandra
-----Original Message-----
From: Ted Yu [mailto:[email protected]]
Sent: Thursday, April 10, 2014 5:36 PM
To: [email protected]
Cc: [email protected]
Subject: Re: endpoint coprocessor
Here is a reference implementation for aggregation :
http://search-hadoop.com/c/HBase:hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/AggregateImplementation.java||Hbase+aggregation+endpoint
You can find it in hbase source code.
Cheers
On Apr 10, 2014, at 4:29 AM, "Bogala, Chandra Reddy"
<[email protected]<mailto:[email protected]>> wrote:
> Hi,
> I am planning to write endpoint coprocessor to calculate TOP N results for my
> usecase. I got confused with old apis and new apis.
> I followed below links and try to implement. But looks like api's changed a
> lot. I don't see many of these classes in hbase jars. We are using Hbase 0.96.
> Can anyone point to the latest document/apis?. And if possible sample code to
> calculate top N.
>
> https://blogs.apache.org/hbase/entry/coprocessor_introduction
> https://www.youtube.com/watch?v=xHvJhuGGOKc
>
> Thanks,
> Chandra
>
>
