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
-
Constructor Summary
ConstructorDescriptionDevNullAsyncConnection
(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 TypeMethodDescriptionvoid
void
close()
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>
getHbck()
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
isClosed()
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
-
-
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 interfaceorg.apache.hadoop.hbase.client.AsyncConnection
-
clearRegionLocationCache
- Specified by:
clearRegionLocationCache
in interfaceorg.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 interfaceorg.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 interfaceorg.apache.hadoop.hbase.client.AsyncConnection
-
getAdminBuilder
- Specified by:
getAdminBuilder
in interfaceorg.apache.hadoop.hbase.client.AsyncConnection
-
getAdminBuilder
- Specified by:
getAdminBuilder
in interfaceorg.apache.hadoop.hbase.client.AsyncConnection
-
getBufferedMutatorBuilder
public org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName) - Specified by:
getBufferedMutatorBuilder
in interfaceorg.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 interfaceorg.apache.hadoop.hbase.client.AsyncConnection
-
getHbck
- Specified by:
getHbck
in interfaceorg.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 interfaceorg.apache.hadoop.hbase.client.AsyncConnection
- Throws:
IOException
-
isClosed
- Specified by:
isClosed
in interfaceorg.apache.hadoop.hbase.client.AsyncConnection
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- 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 interfaceorg.apache.hadoop.hbase.client.AsyncConnection
-
getConfiguration
- Specified by:
getConfiguration
in interfaceorg.apache.hadoop.hbase.client.AsyncConnection
-