Package org.apache.hadoop.hbase.client

Class RawAsyncTableImpl.CoprocessorServiceBuilderImpl<S,R>

java.lang.Object

org.apache.hadoop.hbase.client.RawAsyncTableImpl.CoprocessorServiceBuilderImpl<S,R>

All Implemented Interfaces:

AsyncTable.CoprocessorServiceBuilder<S,R>

Enclosing class:

RawAsyncTableImpl

private final class RawAsyncTableImpl.CoprocessorServiceBuilderImpl<S,R>
extends Object
implements AsyncTable.CoprocessorServiceBuilder<S,R>

Field Summary

Fields

Modifier and Type	Field	Description
private final ServiceCaller<S,R>	callable
private final AsyncTable.PartialResultCoprocessorCallback<S,R>	callback
private byte[]	endKey
private boolean	endKeyInclusive
private byte[]	startKey
private boolean	startKeyInclusive
private final Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S>	stubMaker

Constructor Summary

Constructors

Constructor	Description
CoprocessorServiceBuilderImpl(Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker, ServiceCaller<S,R> callable, AsyncTable.PartialResultCoprocessorCallback<S,R> callback)

Method Summary

Modifier and Type	Method	Description
void	execute()	Execute the coprocessorService request.
RawAsyncTableImpl.CoprocessorServiceBuilderImpl<S,R>	fromRow(byte[] startKey, boolean inclusive)	Specify a start row
RawAsyncTableImpl.CoprocessorServiceBuilderImpl<S,R>	toRow(byte[] endKey, boolean inclusive)	Specify a stop row

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.client.AsyncTable.CoprocessorServiceBuilder

fromRow, toRow

Field Details

stubMaker

private final Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker

callable

private final ServiceCaller<S,R> callable

callback

private final AsyncTable.PartialResultCoprocessorCallback<S,R> callback

startKey

private byte[] startKey

startKeyInclusive

private boolean startKeyInclusive

endKey

private byte[] endKey

endKeyInclusive

private boolean endKeyInclusive

Constructor Details

CoprocessorServiceBuilderImpl

public CoprocessorServiceBuilderImpl(Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker,
 ServiceCaller<S,R> callable,
 AsyncTable.PartialResultCoprocessorCallback<S,R> callback)

Method Details

fromRow

public RawAsyncTableImpl.CoprocessorServiceBuilderImpl<S,R> fromRow(byte[] startKey,
 boolean inclusive)

Description copied from interface: AsyncTable.CoprocessorServiceBuilder

Specify a start row

Specified by:

fromRow in interface AsyncTable.CoprocessorServiceBuilder<S,R>

Parameters:

startKey - start region selection with region containing this row

inclusive - whether to include the startKey

toRow

public RawAsyncTableImpl.CoprocessorServiceBuilderImpl<S,R> toRow(byte[] endKey,
 boolean inclusive)

Description copied from interface: AsyncTable.CoprocessorServiceBuilder

Specify a stop row

Specified by:

toRow in interface AsyncTable.CoprocessorServiceBuilder<S,R>

Parameters:

endKey - select regions up to and including the region containing this row

inclusive - whether to include the endKey

execute

public void execute()

Description copied from interface: AsyncTable.CoprocessorServiceBuilder

Execute the coprocessorService request. You can get the response through the AsyncTable.CoprocessorCallback.

Specified by:

execute in interface AsyncTable.CoprocessorServiceBuilder<S,R>