hbase-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kiru Pakkirisamy <kirupakkiris...@yahoo.com>
Subject Re: Co-Processors in Hase 0.95.2 version
Date Mon, 23 Sep 2013 16:42:42 GMT
Yeshwanth,
With 0.95.2 coprocessors use protocol instead of serializing Java objects, one would use protobuf.
Most of the tutorials on protobuf are mainly about the data structures and not much about
the rpc mechanism, which is what we use in 0.95.2

The RPC is defined like this in a proto file -

service TermIdSearchService {
rpc getTermIdWithCount(TermList)
returns (TermIdCountList);
}

Then it is implemented like this (this is also what to install as coprocessor in the table)


public class TermIdSearchEndpointV2 extends
TermIdSearchProtocol.TermIdSearchService implements Coprocessor,
CoprocessorService  {
.....

@Override
public void getTermIdWithCount(RpcController controller,
TermIdSearchProtocol.TermList termlist,
RpcCallback<TermIdSearchProtocol.TermIdCountList> callback) {
....
}
----

}


Regards,
- kiru


Kiru Pakkirisamy | webcloudtech.wordpress.com


________________________________
 From: yeshwanth kumar <yeshwanth43@gmail.com>
To: user@hbase.apache.org 
Sent: Sunday, September 22, 2013 10:14 PM
Subject: Co-Processors in Hase 0.95.2 version
 

Hi,

facing some difficulty to write the co-processors in hbase 0.95.2 version,
looking for some tutorials and examples....

can anyone provide me some examples


how the co-processors are related with protobuffer's ..

Thanks
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message