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 and Description
private ServiceCaller<S,R>	callable
private AsyncTable.CoprocessorCallback<R>	callback
private byte[]	endKey
private boolean	endKeyInclusive
private byte[]	startKey
private boolean	startKeyInclusive
private Function<com.google.protobuf.RpcChannel,S>	stubMaker

Constructor Summary

Constructors

Constructor and Description
CoprocessorServiceBuilderImpl(Function<com.google.protobuf.RpcChannel,S> stubMaker, ServiceCaller<S,R> callable, AsyncTable.CoprocessorCallback<R> callback)

Method Summary

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

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 Detail

stubMaker

private final Function<com.google.protobuf.RpcChannel,S> stubMaker

callable

private final ServiceCaller<S,R> callable

callback

private final AsyncTable.CoprocessorCallback<R> callback

startKey

private byte[] startKey

startKeyInclusive

private boolean startKeyInclusive

endKey

private byte[] endKey

endKeyInclusive

private boolean endKeyInclusive

Constructor Detail

CoprocessorServiceBuilderImpl

public CoprocessorServiceBuilderImpl(Function<com.google.protobuf.RpcChannel,S> stubMaker,
                                     ServiceCaller<S,R> callable,
                                     AsyncTable.CoprocessorCallback<R> callback)

Method Detail

fromRow

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

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)

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>