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.
  • Constructor Details

  • 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<org.apache.hbase.thirdparty.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<org.apache.hbase.thirdparty.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>