DummyAsyncTable (Apache HBase 2.5.0 Test API)

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>, org.apache.hadoop.hbase.client.AsyncTable.CoprocessorServiceBuilder<S,R>

Constructor Summary

Constructors
Constructor and Description

DummyAsyncTable()

Constructors
Constructor and Description
`DummyAsyncTable()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and 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)`
`CompletableFuture<org.apache.hadoop.hbase.client.CheckAndMutateResult>`	`checkAndMutate(org.apache.hadoop.hbase.client.CheckAndMutate checkAndMutate)`
`List<CompletableFuture<org.apache.hadoop.hbase.client.CheckAndMutateResult>>`	`checkAndMutate(List<org.apache.hadoop.hbase.client.CheckAndMutate> checkAndMutates)`
`<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)`
`<S,R> CompletableFuture<R>`	`coprocessorService(Function<com.google.protobuf.RpcChannel,S> stubMaker, org.apache.hadoop.hbase.client.ServiceCaller<S,R> callable, byte[] row)`
`CompletableFuture<Void>`	`delete(org.apache.hadoop.hbase.client.Delete delete)`
`List<CompletableFuture<Void>>`	`delete(List<org.apache.hadoop.hbase.client.Delete> deletes)`
`CompletableFuture<org.apache.hadoop.hbase.client.Result>`	`get(org.apache.hadoop.hbase.client.Get get)`
`List<CompletableFuture<org.apache.hadoop.hbase.client.Result>>`	`get(List<org.apache.hadoop.hbase.client.Get> gets)`
`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()`
`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 Detail
  - DummyAsyncTable
```
public DummyAsyncTable()
```
- Method Detail
  - 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>
  - 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>

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

Nested Class Summary

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

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

DummyAsyncTable

Method Detail

getName

getConfiguration

getDescriptor

getRegionLocator

getRpcTimeout

getReadRpcTimeout

getWriteRpcTimeout

getOperationTimeout

getScanTimeout

get

put

delete

append

increment

checkAndMutate

checkAndMutate

checkAndMutate

checkAndMutate

mutateRow

scan

getScanner

scanAll

get

put

delete

batch

coprocessorService

coprocessorService