Mailing-List: contact user-help@hbase.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@hbase.apache.org
Received-SPF: pass (nike.apache.org: domain of Chandra.Bogala@gs.com
 designates 204.4.178.100 as permitted sender)
From: "Bogala, Chandra Reddy" <Chandra.Bogala@gs.com>
To: "'user@hbase.apache.org'" <user@hbase.apache.org>
Date: Fri, 11 Apr 2014 21:20:06 -0400
Subject: RE: endpoint coprocessor
Thread-Topic: endpoint coprocessor
Thread-Index: Ac9VqSpAtvcF+TIrRoqRhNgWQQWKqQAQnDLw
Message-ID: 
 <0A88212BF9DDF54FBEE61A2C1965291D032B587D3B@GSCMBLP12EX.firmwide.corp.gs.com>
References: 
 <0A88212BF9DDF54FBEE61A2C1965291D032B587CB2@GSCMBLP12EX.firmwide.corp.gs.com>
	<CA+r7YvkXkgK1C26W3phn8WHXxwH0B14yCBdwW_mxtpLd2uysDg@mail.gmail.com>
	<0A88212BF9DDF54FBEE61A2C1965291D032B587D2D@GSCMBLP12EX.firmwide.corp.gs.com>
 <CALte62y2VKA573W1ZoHDuh2AFJDJ-_VjC1Vm4SWCTNgtXE_jRg@mail.gmail.com>
In-Reply-To: 
 <CALte62y2VKA573W1ZoHDuh2AFJDJ-_VjC1Vm4SWCTNgtXE_jRg@mail.gmail.com>
Accept-Language: en-US
Content-Language: en-US
acceptlanguage: en-US
Content-Type: multipart/alternative;
	boundary="_000_0A88212BF9DDF54FBEE61A2C1965291D032B587D3BGSCMBLP12EXfi_"
MIME-Version: 1.0

--_000_0A88212BF9DDF54FBEE61A2C1965291D032B587D3BGSCMBLP12EXfi_
Content-Type: text/plain; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable

Thanks Yu. My understanding is, this coprocessor is available as part of Hb=
ase server components. So I should be able to attach this coprocessor to an=
y of my tables by using alter table command.


alter 'demo-table','COPROCESSOR' =3D>'<XXXX.jar>|class|priority|args'


Then from hbase shell, I should be able to call this coprocessor with comma=
nd. Same like how we do scan and filter. Is there any command like below(fi=
lter command) calling a coprocessor. So that it will run in region server a=
nd return back results?.


scan 'demo-table', {FILTER =3D> org.apache.hadoop.hbase.filter.RowFilter.ne=
w(CompareFilter::CompareOp.valueOf('EQUAL'),SubstringComparator.new("10001|=
1395309600"))}


I am trying to figure out a simple call mechanism(client) of coprocessor. I=
f by default those classes and calling mechanism not available from hbase s=
hell. Then planning to use java client code to invoke coprocessor.

Any pointers to java client to invoke aggregation<http://search-hadoop.com/=
c/HBase:hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/Aggr=
egateImplementation.java||Hbase+aggregation+endpoint> coprocessor will be h=
elpful.


Thanks,

Chandra


-----Original Message-----
From: Ted Yu [mailto:yuzhihong@gmail.com]
Sent: Friday, April 11, 2014 10:42 PM
To: user@hbase.apache.org
Subject: Re: endpoint coprocessor


Please take a look at :

hbase-shell/src/main/ruby/hbase/security.rb


for example on how coprocessor is activated from shell.


Cheers


On Fri, Apr 11, 2014 at 11:06 AM, Bogala, Chandra Reddy < Chandra.Bogala@gs=
.com<mailto:Chandra.Bogala@gs.com>> wrote:


> Thank you. I am aware of this challenge. How to call below coprocessor

> from client. Can I call this coprocessor from hbase shell?.  I am new

> to Hbase. So may be asking very dumb questions.

>

> Thanks,

> Chandra

>

> -----Original Message-----

> From: Asaf Mesika [mailto:asaf.mesika@gmail.com]

> Sent: Friday, April 11, 2014 12:10 PM

> To: user@hbase.apache.org<mailto:user@hbase.apache.org>

> Subject: Re: endpoint coprocessor

>

> Bear in mind each region will return its top n, then you will have to

> run another top n in your client code. This introduce a numerical

> error : top on top.

>

> On Thursday, April 10, 2014, Bogala, Chandra Reddy

> <Chandra.Bogala@gs.com<mailto:Chandra.Bogala@gs.com>>

> 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

> > HBase Coprocessors - Deploy shared functionality directly on the

> > cluster<https://www.youtube.com/watch?v=3DxHvJhuGGOKc>

> >

> > Thanks,

> > Chandra

> >

> >

> >

>

--_000_0A88212BF9DDF54FBEE61A2C1965291D032B587D3BGSCMBLP12EXfi_--