public class DummyAsyncClusterConnection extends Object implements org.apache.hadoop.hbase.client.AsyncClusterConnection
AsyncClusterConnection
.Constructor and Description |
---|
DummyAsyncClusterConnection() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Boolean> |
bulkLoad(org.apache.hadoop.hbase.TableName tableName,
List<org.apache.hadoop.hbase.util.Pair<byte[],String>> familyPaths,
byte[] row,
boolean assignSeqNum,
org.apache.hadoop.security.token.Token<?> userToken,
String bulkToken,
boolean copyFiles,
List<String> clusterIds,
boolean replicate) |
CompletableFuture<Void> |
cleanupBulkLoad(org.apache.hadoop.hbase.TableName tableName,
String bulkToken) |
void |
clearRegionLocationCache() |
void |
close() |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse> |
flush(byte[] regionName,
boolean writeFlushWALMarker) |
org.apache.hadoop.hbase.client.AsyncAdminBuilder |
getAdminBuilder() |
org.apache.hadoop.hbase.client.AsyncAdminBuilder |
getAdminBuilder(ExecutorService pool) |
CompletableFuture<List<org.apache.hadoop.hbase.ServerName>> |
getAllBootstrapNodes(org.apache.hadoop.hbase.ServerName regionServer) |
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) |
CompletableFuture<List<org.apache.hadoop.hbase.ServerName>> |
getLiveRegionServers(org.apache.hadoop.hbase.zookeeper.MasterAddressTracker masterAddrTracker,
int count) |
org.apache.hadoop.hbase.client.NonceGenerator |
getNonceGenerator() |
CompletableFuture<org.apache.hadoop.hbase.RegionLocations> |
getRegionLocations(org.apache.hadoop.hbase.TableName tableName,
byte[] row,
boolean reload) |
org.apache.hadoop.hbase.client.AsyncTableRegionLocator |
getRegionLocator(org.apache.hadoop.hbase.TableName tableName) |
org.apache.hadoop.hbase.client.AsyncRegionServerAdmin |
getRegionServerAdmin(org.apache.hadoop.hbase.ServerName serverName) |
org.apache.hadoop.hbase.ipc.RpcClient |
getRpcClient() |
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() |
CompletableFuture<String> |
prepareBulkLoad(org.apache.hadoop.hbase.TableName tableName) |
CompletableFuture<Void> |
replicate(org.apache.hadoop.hbase.client.RegionInfo replica,
List<org.apache.hadoop.hbase.wal.WAL.Entry> entries,
int numRetries,
long rpcTimeoutNs,
long operationTimeoutNs) |
org.apache.hadoop.hbase.client.Connection |
toConnection() |
public DummyAsyncClusterConnection()
public org.apache.hadoop.conf.Configuration getConfiguration()
getConfiguration
in interface org.apache.hadoop.hbase.client.AsyncConnection
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.AsyncRegionServerAdmin getRegionServerAdmin(org.apache.hadoop.hbase.ServerName serverName)
getRegionServerAdmin
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
public org.apache.hadoop.hbase.client.NonceGenerator getNonceGenerator()
getNonceGenerator
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
public org.apache.hadoop.hbase.ipc.RpcClient getRpcClient()
getRpcClient
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse> flush(byte[] regionName, boolean writeFlushWALMarker)
flush
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
public CompletableFuture<org.apache.hadoop.hbase.RegionLocations> getRegionLocations(org.apache.hadoop.hbase.TableName tableName, byte[] row, boolean reload)
getRegionLocations
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
public CompletableFuture<String> prepareBulkLoad(org.apache.hadoop.hbase.TableName tableName)
prepareBulkLoad
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
public CompletableFuture<Boolean> bulkLoad(org.apache.hadoop.hbase.TableName tableName, List<org.apache.hadoop.hbase.util.Pair<byte[],String>> familyPaths, byte[] row, boolean assignSeqNum, org.apache.hadoop.security.token.Token<?> userToken, String bulkToken, boolean copyFiles, List<String> clusterIds, boolean replicate)
bulkLoad
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
public CompletableFuture<Void> cleanupBulkLoad(org.apache.hadoop.hbase.TableName tableName, String bulkToken)
cleanupBulkLoad
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
public org.apache.hadoop.hbase.client.Connection toConnection()
toConnection
in interface org.apache.hadoop.hbase.client.AsyncConnection
public CompletableFuture<List<org.apache.hadoop.hbase.ServerName>> getLiveRegionServers(org.apache.hadoop.hbase.zookeeper.MasterAddressTracker masterAddrTracker, int count)
getLiveRegionServers
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
public CompletableFuture<List<org.apache.hadoop.hbase.ServerName>> getAllBootstrapNodes(org.apache.hadoop.hbase.ServerName regionServer)
getAllBootstrapNodes
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
public CompletableFuture<Void> replicate(org.apache.hadoop.hbase.client.RegionInfo replica, List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, int numRetries, long rpcTimeoutNs, long operationTimeoutNs)
replicate
in interface org.apache.hadoop.hbase.client.AsyncClusterConnection
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.