public static class TestWALEntrySinkFilter.DevNullAsyncConnection extends Object implements org.apache.hadoop.hbase.client.AsyncConnection
AsyncTable.batchAll(java.util.List<? extends org.apache.hadoop.hbase.client.Row>)
.Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.conf.Configuration |
conf |
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) |
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() |
private final org.apache.hadoop.conf.Configuration conf
public DevNullAsyncConnection(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.ConnectionRegistry registry, String clusterId, org.apache.hadoop.hbase.security.User user)
public org.apache.hadoop.hbase.client.AsyncTableRegionLocator getRegionLocator(org.apache.hadoop.hbase.TableName tableName)
getRegionLocator
in interface org.apache.hadoop.hbase.client.AsyncConnection
public void clearRegionLocationCache()
clearRegionLocationCache
in interface org.apache.hadoop.hbase.client.AsyncConnection
public org.apache.hadoop.hbase.client.AsyncTableBuilder<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer> getTableBuilder(org.apache.hadoop.hbase.TableName tableName)
getTableBuilder
in interface org.apache.hadoop.hbase.client.AsyncConnection
public org.apache.hadoop.hbase.client.AsyncTableBuilder<org.apache.hadoop.hbase.client.ScanResultConsumer> getTableBuilder(org.apache.hadoop.hbase.TableName tableName, ExecutorService pool)
getTableBuilder
in interface org.apache.hadoop.hbase.client.AsyncConnection
public org.apache.hadoop.hbase.client.AsyncAdminBuilder getAdminBuilder()
getAdminBuilder
in interface org.apache.hadoop.hbase.client.AsyncConnection
public org.apache.hadoop.hbase.client.AsyncAdminBuilder getAdminBuilder(ExecutorService pool)
getAdminBuilder
in interface org.apache.hadoop.hbase.client.AsyncConnection
public org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName)
getBufferedMutatorBuilder
in interface org.apache.hadoop.hbase.client.AsyncConnection
public org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName, ExecutorService pool)
getBufferedMutatorBuilder
in interface org.apache.hadoop.hbase.client.AsyncConnection
public CompletableFuture<org.apache.hadoop.hbase.client.Hbck> getHbck()
getHbck
in interface org.apache.hadoop.hbase.client.AsyncConnection
public org.apache.hadoop.hbase.client.Hbck getHbck(org.apache.hadoop.hbase.ServerName masterServer) throws IOException
getHbck
in interface org.apache.hadoop.hbase.client.AsyncConnection
IOException
public boolean isClosed()
isClosed
in interface org.apache.hadoop.hbase.client.AsyncConnection
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public org.apache.hadoop.hbase.client.AsyncTable<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer> getTable(org.apache.hadoop.hbase.TableName tableName)
getTable
in interface org.apache.hadoop.hbase.client.AsyncConnection
public org.apache.hadoop.conf.Configuration getConfiguration()
getConfiguration
in interface org.apache.hadoop.hbase.client.AsyncConnection
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.