Package org.apache.hadoop.hbase.client

Class DummyAsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

java.lang.Object

org.apache.hadoop.hbase.client.DummyAsyncTable<C>

All Implemented Interfaces:

org.apache.hadoop.hbase.client.AsyncTable<C>

public class DummyAsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>
extends Object
implements org.apache.hadoop.hbase.client.AsyncTable<C>

Can be overridden in UT if you only want to implement part of the methods in AsyncTable.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.client.AsyncTable

org.apache.hadoop.hbase.client.AsyncTable.CheckAndMutateBuilder, org.apache.hadoop.hbase.client.AsyncTable.CheckAndMutateWithFilterBuilder, org.apache.hadoop.hbase.client.AsyncTable.CoprocessorCallback<R extends Object>, org.apache.hadoop.hbase.client.AsyncTable.CoprocessorServiceBuilder<S extends Object,R extends Object>

Constructor Summary

Constructors

Constructor	Description
DummyAsyncTable()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<org.apache.hadoop.hbase.client.Result>	append(org.apache.hadoop.hbase.client.Append append)
<T> List<CompletableFuture<T>>	batch(List<? extends org.apache.hadoop.hbase.client.Row> actions)
org.apache.hadoop.hbase.client.AsyncTable.CheckAndMutateBuilder	checkAndMutate(byte[] row, byte[] family)
org.apache.hadoop.hbase.client.AsyncTable.CheckAndMutateWithFilterBuilder	checkAndMutate(byte[] row, org.apache.hadoop.hbase.filter.Filter filter)
List<CompletableFuture<org.apache.hadoop.hbase.client.CheckAndMutateResult>>	checkAndMutate(List<org.apache.hadoop.hbase.client.CheckAndMutate> checkAndMutates)
CompletableFuture<org.apache.hadoop.hbase.client.CheckAndMutateResult>	checkAndMutate(org.apache.hadoop.hbase.client.CheckAndMutate checkAndMutate)
<S, R> CompletableFuture<R>	coprocessorService(Function<com.google.protobuf.RpcChannel,S> stubMaker, org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable, byte[] row)
<S, R> org.apache.hadoop.hbase.client.AsyncTable.CoprocessorServiceBuilder<S,R>	coprocessorService(Function<com.google.protobuf.RpcChannel,S> stubMaker, org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable, org.apache.hadoop.hbase.client.AsyncTable.CoprocessorCallback<R> callback)
List<CompletableFuture<Void>>	delete(List<org.apache.hadoop.hbase.client.Delete> deletes)
CompletableFuture<Void>	delete(org.apache.hadoop.hbase.client.Delete delete)
List<CompletableFuture<org.apache.hadoop.hbase.client.Result>>	get(List<org.apache.hadoop.hbase.client.Get> gets)
CompletableFuture<org.apache.hadoop.hbase.client.Result>	get(org.apache.hadoop.hbase.client.Get get)
org.apache.hadoop.conf.Configuration	getConfiguration()
CompletableFuture<org.apache.hadoop.hbase.client.TableDescriptor>	getDescriptor()
org.apache.hadoop.hbase.TableName	getName()
long	getOperationTimeout(TimeUnit unit)
long	getReadRpcTimeout(TimeUnit unit)
org.apache.hadoop.hbase.client.AsyncTableRegionLocator	getRegionLocator()
Map<String,byte[]>	getRequestAttributes()
long	getRpcTimeout(TimeUnit unit)
org.apache.hadoop.hbase.client.ResultScanner	getScanner(org.apache.hadoop.hbase.client.Scan scan)
long	getScanTimeout(TimeUnit unit)
long	getWriteRpcTimeout(TimeUnit unit)
CompletableFuture<org.apache.hadoop.hbase.client.Result>	increment(org.apache.hadoop.hbase.client.Increment increment)
CompletableFuture<org.apache.hadoop.hbase.client.Result>	mutateRow(org.apache.hadoop.hbase.client.RowMutations mutation)
List<CompletableFuture<Void>>	put(List<org.apache.hadoop.hbase.client.Put> puts)
CompletableFuture<Void>	put(org.apache.hadoop.hbase.client.Put put)
void	scan(org.apache.hadoop.hbase.client.Scan scan, C consumer)
CompletableFuture<List<org.apache.hadoop.hbase.client.Result>>	scanAll(org.apache.hadoop.hbase.client.Scan scan)

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

batchAll, checkAndMutateAll, deleteAll, exists, exists, existsAll, getAll, getScanner, getScanner, incrementColumnValue, incrementColumnValue, putAll

Constructor Details

DummyAsyncTable

public DummyAsyncTable()

Method Details

getName

public org.apache.hadoop.hbase.TableName getName()

Specified by:

getName in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Specified by:

getConfiguration in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

getDescriptor

public CompletableFuture<org.apache.hadoop.hbase.client.TableDescriptor> getDescriptor()

Specified by:

getDescriptor in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

getRegionLocator

public org.apache.hadoop.hbase.client.AsyncTableRegionLocator getRegionLocator()

Specified by:

getRegionLocator in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

getRpcTimeout

public long getRpcTimeout(TimeUnit unit)

Specified by:

getRpcTimeout in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

getReadRpcTimeout

public long getReadRpcTimeout(TimeUnit unit)

Specified by:

getReadRpcTimeout in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

getWriteRpcTimeout

public long getWriteRpcTimeout(TimeUnit unit)

Specified by:

getWriteRpcTimeout in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

getOperationTimeout

public long getOperationTimeout(TimeUnit unit)

Specified by:

getOperationTimeout in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

getScanTimeout

public long getScanTimeout(TimeUnit unit)

Specified by:

getScanTimeout in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

getRequestAttributes

public Map<String,byte[]> getRequestAttributes()

Specified by:

getRequestAttributes in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

get

public CompletableFuture<org.apache.hadoop.hbase.client.Result> get(org.apache.hadoop.hbase.client.Get get)

Specified by:

get in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

put

public CompletableFuture<Void> put(org.apache.hadoop.hbase.client.Put put)

Specified by:

put in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

delete

public CompletableFuture<Void> delete(org.apache.hadoop.hbase.client.Delete delete)

Specified by:

delete in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

append

public CompletableFuture<org.apache.hadoop.hbase.client.Result> append(org.apache.hadoop.hbase.client.Append append)

Specified by:

append in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

increment

public CompletableFuture<org.apache.hadoop.hbase.client.Result> increment(org.apache.hadoop.hbase.client.Increment increment)

Specified by:

increment in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

checkAndMutate

public org.apache.hadoop.hbase.client.AsyncTable.CheckAndMutateBuilder checkAndMutate(byte[] row,
 byte[] family)

Specified by:

checkAndMutate in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

checkAndMutate

public org.apache.hadoop.hbase.client.AsyncTable.CheckAndMutateWithFilterBuilder checkAndMutate(byte[] row,
 org.apache.hadoop.hbase.filter.Filter filter)

Specified by:

checkAndMutate in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

checkAndMutate

public CompletableFuture<org.apache.hadoop.hbase.client.CheckAndMutateResult> checkAndMutate(org.apache.hadoop.hbase.client.CheckAndMutate checkAndMutate)

Specified by:

checkAndMutate in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

checkAndMutate

public List<CompletableFuture<org.apache.hadoop.hbase.client.CheckAndMutateResult>> checkAndMutate(List<org.apache.hadoop.hbase.client.CheckAndMutate> checkAndMutates)

Specified by:

checkAndMutate in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

mutateRow

public CompletableFuture<org.apache.hadoop.hbase.client.Result> mutateRow(org.apache.hadoop.hbase.client.RowMutations mutation)

Specified by:

mutateRow in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

scan

public void scan(org.apache.hadoop.hbase.client.Scan scan,
 C consumer)

Specified by:

scan in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

getScanner

public org.apache.hadoop.hbase.client.ResultScanner getScanner(org.apache.hadoop.hbase.client.Scan scan)

Specified by:

getScanner in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

scanAll

public CompletableFuture<List<org.apache.hadoop.hbase.client.Result>> scanAll(org.apache.hadoop.hbase.client.Scan scan)

Specified by:

scanAll in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

get

public List<CompletableFuture<org.apache.hadoop.hbase.client.Result>> get(List<org.apache.hadoop.hbase.client.Get> gets)

Specified by:

get in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

put

public List<CompletableFuture<Void>> put(List<org.apache.hadoop.hbase.client.Put> puts)

Specified by:

put in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

delete

public List<CompletableFuture<Void>> delete(List<org.apache.hadoop.hbase.client.Delete> deletes)

Specified by:

delete in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

batch

public <T> List<CompletableFuture<T>> batch(List<? extends org.apache.hadoop.hbase.client.Row> actions)

Specified by:

batch in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

coprocessorService

public <S,
R> CompletableFuture<R> coprocessorService(Function<com.google.protobuf.RpcChannel,S> stubMaker,
 org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable,
 byte[] row)

Specified by:

coprocessorService in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>

coprocessorService

public <S,
R>
org.apache.hadoop.hbase.client.AsyncTable.CoprocessorServiceBuilder<S,R> coprocessorService(Function<com.google.protobuf.RpcChannel,S> stubMaker,
 org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable,
 org.apache.hadoop.hbase.client.AsyncTable.CoprocessorCallback<R> callback)

Specified by:

coprocessorService in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>