org.apache.hadoop.hbase.client

Interface AsyncTable.CoprocessorServiceBuilder<S,R>

Type Parameters:

S - the type of the protobuf Service you want to call.

R - the type of the return value.

Enclosing interface:

AsyncTable<C extends ScanResultConsumerBase>

public static interface AsyncTable.CoprocessorServiceBuilder<S,R>

Helper class for sending coprocessorService request that executes a coprocessor call on regions which are covered by a range.

If fromRow is not specified the selection will start with the first table region. If toRow is not specified the selection will continue through the last table region.

Method Summary

Modifier and Type	Method and Description
void	execute() Execute the coprocessorService request.
default AsyncTable.CoprocessorServiceBuilder<S,R>	fromRow(byte[] startKey)
AsyncTable.CoprocessorServiceBuilder<S,R>	fromRow(byte[] startKey, boolean inclusive)
default AsyncTable.CoprocessorServiceBuilder<S,R>	toRow(byte[] endKey)
AsyncTable.CoprocessorServiceBuilder<S,R>	toRow(byte[] endKey, boolean inclusive)

Method Detail

fromRow

default AsyncTable.CoprocessorServiceBuilder<S,R> fromRow(byte[] startKey)

Parameters:

startKey - start region selection with region containing this row, inclusive.

fromRow

AsyncTable.CoprocessorServiceBuilder<S,R> fromRow(byte[] startKey,
                                                  boolean inclusive)

Parameters:

startKey - start region selection with region containing this row

inclusive - whether to include the startKey

toRow

default AsyncTable.CoprocessorServiceBuilder<S,R> toRow(byte[] endKey)

Parameters:

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

toRow

AsyncTable.CoprocessorServiceBuilder<S,R> toRow(byte[] endKey,
                                                boolean inclusive)

Parameters:

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

inclusive - whether to include the endKey

execute

void execute()

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