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>, org.apache.hadoop.hbase.client.AsyncTable.PartialResultCoprocessorCallback<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<org.apache.hbase.thirdparty.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<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)
     
    <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.PartialResultCoprocessorCallback<S,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

  • 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>

    • 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.PartialResultCoprocessorCallback<S,R> callback)
      Specified by:
      coprocessorService in interface org.apache.hadoop.hbase.client.AsyncTable<C extends org.apache.hadoop.hbase.client.ScanResultConsumerBase>