org.apache.hadoop.hbase.replication.regionserver

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 and Description
private org.apache.hadoop.conf.Configuration	conf

Constructor Summary

Constructors

Constructor and Description
DevNullAsyncConnection(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.ConnectionRegistry registry, String clusterId, org.apache.hadoop.hbase.security.User user)

Method Summary

Modifier and Type	Method and Description
void	clearRegionLocationCache()
void	close()
org.apache.hadoop.hbase.client.AsyncAdminBuilder	getAdminBuilder()
org.apache.hadoop.hbase.client.AsyncAdminBuilder	getAdminBuilder(ExecutorService pool)
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	getConfiguration()
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 Detail

conf

private final org.apache.hadoop.conf.Configuration conf

Constructor Detail

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)

Method Detail

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 Closeable

Specified by:

close in interface AutoCloseable

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