Class TestWALEntrySinkFilter.DevNullAsyncConnection

java.lang.Object
org.apache.hadoop.hbase.replication.regionserver.TestWALEntrySinkFilter.DevNullAsyncConnection
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.client.AsyncConnection
Enclosing class:
TestWALEntrySinkFilter

public static class TestWALEntrySinkFilter.DevNullAsyncConnection extends Object implements org.apache.hadoop.hbase.client.AsyncConnection
A DevNull AsyncConnection whose only purpose is checking what edits made it through. See down in AsyncTable.batchAll(java.util.List<? extends org.apache.hadoop.hbase.client.Row>).
  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final org.apache.hadoop.conf.Configuration
     
  • Constructor Summary

    Constructors
    Constructor
    Description
    DevNullAsyncConnection(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.ConnectionRegistry registry, String clusterId, org.apache.hadoop.hbase.security.User user, Map<String,byte[]> connectionAttributes)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    void
     
    void
     
    org.apache.hadoop.hbase.client.AsyncAdminBuilder
     
    org.apache.hadoop.hbase.client.AsyncAdminBuilder
     
    org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
    getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName)
     
    org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
    getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName, ExecutorService pool)
     
    org.apache.hadoop.conf.Configuration
     
    CompletableFuture<org.apache.hadoop.hbase.client.Hbck>
     
    org.apache.hadoop.hbase.client.Hbck
    getHbck(org.apache.hadoop.hbase.ServerName masterServer)
     
    org.apache.hadoop.hbase.client.AsyncTableRegionLocator
    getRegionLocator(org.apache.hadoop.hbase.TableName tableName)
     
    org.apache.hadoop.hbase.client.AsyncTable<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer>
    getTable(org.apache.hadoop.hbase.TableName tableName)
     
    org.apache.hadoop.hbase.client.AsyncTableBuilder<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer>
    getTableBuilder(org.apache.hadoop.hbase.TableName tableName)
     
    org.apache.hadoop.hbase.client.AsyncTableBuilder<org.apache.hadoop.hbase.client.ScanResultConsumer>
    getTableBuilder(org.apache.hadoop.hbase.TableName tableName, ExecutorService pool)
     
    boolean
     

    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.AsyncConnection

    getAdmin, getAdmin, getBufferedMutator, getBufferedMutator, getTable
  • Field Details

    • conf

      private final org.apache.hadoop.conf.Configuration conf
  • Constructor Details

    • DevNullAsyncConnection

      public DevNullAsyncConnection(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.ConnectionRegistry registry, String clusterId, org.apache.hadoop.hbase.security.User user, Map<String,byte[]> connectionAttributes)
  • Method Details

    • getRegionLocator

      public org.apache.hadoop.hbase.client.AsyncTableRegionLocator getRegionLocator(org.apache.hadoop.hbase.TableName tableName)
      Specified by:
      getRegionLocator in interface org.apache.hadoop.hbase.client.AsyncConnection
    • clearRegionLocationCache

      public void clearRegionLocationCache()
      Specified by:
      clearRegionLocationCache in interface org.apache.hadoop.hbase.client.AsyncConnection
    • getTableBuilder

      public org.apache.hadoop.hbase.client.AsyncTableBuilder<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer> getTableBuilder(org.apache.hadoop.hbase.TableName tableName)
      Specified by:
      getTableBuilder in interface org.apache.hadoop.hbase.client.AsyncConnection
    • getTableBuilder

      public org.apache.hadoop.hbase.client.AsyncTableBuilder<org.apache.hadoop.hbase.client.ScanResultConsumer> getTableBuilder(org.apache.hadoop.hbase.TableName tableName, ExecutorService pool)
      Specified by:
      getTableBuilder in interface org.apache.hadoop.hbase.client.AsyncConnection
    • getAdminBuilder

      public org.apache.hadoop.hbase.client.AsyncAdminBuilder getAdminBuilder()
      Specified by:
      getAdminBuilder in interface org.apache.hadoop.hbase.client.AsyncConnection
    • getAdminBuilder

      public org.apache.hadoop.hbase.client.AsyncAdminBuilder getAdminBuilder(ExecutorService pool)
      Specified by:
      getAdminBuilder in interface org.apache.hadoop.hbase.client.AsyncConnection
    • getBufferedMutatorBuilder

      public org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName)
      Specified by:
      getBufferedMutatorBuilder in interface org.apache.hadoop.hbase.client.AsyncConnection
    • getBufferedMutatorBuilder

      public org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName, ExecutorService pool)
      Specified by:
      getBufferedMutatorBuilder in interface org.apache.hadoop.hbase.client.AsyncConnection
    • getHbck

      public CompletableFuture<org.apache.hadoop.hbase.client.Hbck> getHbck()
      Specified by:
      getHbck in interface org.apache.hadoop.hbase.client.AsyncConnection
    • getHbck

      public org.apache.hadoop.hbase.client.Hbck getHbck(org.apache.hadoop.hbase.ServerName masterServer) throws IOException
      Specified by:
      getHbck in interface org.apache.hadoop.hbase.client.AsyncConnection
      Throws:
      IOException
    • isClosed

      public boolean isClosed()
      Specified by:
      isClosed in interface org.apache.hadoop.hbase.client.AsyncConnection
    • close

      public void close() throws IOException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Throws:
      IOException
    • getTable

      public org.apache.hadoop.hbase.client.AsyncTable<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer> getTable(org.apache.hadoop.hbase.TableName tableName)
      Specified by:
      getTable in interface org.apache.hadoop.hbase.client.AsyncConnection
    • getConfiguration

      public org.apache.hadoop.conf.Configuration getConfiguration()
      Specified by:
      getConfiguration in interface org.apache.hadoop.hbase.client.AsyncConnection