Packages that use org.apache.hadoop.hbase.client.ServiceCaller
-
org.apache.hadoop.hbase.client.ServiceCaller<S,R>
AsyncTable.PartialResultCoprocessorCallback.getNextCallable(R response,
org.apache.hadoop.hbase.client.RegionInfo region)
Subclasses should implement this to tell AsyncTable whether the given response is "final" or
whether the AsyncTable should send another request to the coprocessor to fetch more results
from the given region.
org.apache.hadoop.hbase.client.ServiceCaller<S,R>
NoopPartialResultCoprocessorCallback.getNextCallable(R response,
org.apache.hadoop.hbase.client.RegionInfo region)
AsyncAdmin.coprocessorService(Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker,
org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable)
Execute the given coprocessor call on the master.
AsyncAdmin.coprocessorService(Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker,
org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable,
org.apache.hadoop.hbase.ServerName serverName)
Execute the given coprocessor call on the given region server.
AsyncTable.coprocessorService(Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker,
org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable,
byte[] row)
Execute the given coprocessor call on the region which contains the given row
.
<S,
R> org.apache.hadoop.hbase.client.AsyncTable.CoprocessorServiceBuilder<S,R>
AsyncTable.coprocessorService(Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker,
org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable,
org.apache.hadoop.hbase.client.AsyncTable.CoprocessorCallback<R> callback)
Execute a coprocessor call on the regions which are covered by a range.
<S,
R> org.apache.hadoop.hbase.client.AsyncTable.CoprocessorServiceBuilder<S,R>
AsyncTable.coprocessorService(Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker,
org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable,
org.apache.hadoop.hbase.client.AsyncTable.PartialResultCoprocessorCallback<S,R> callback)
AsyncAdminClientUtils.coprocessorServiceOnAllRegionServers(org.apache.hadoop.hbase.client.AsyncAdmin asyncAdmin,
Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker,
org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable)
Execute the given coprocessor call on all region servers.