@InterfaceAudience.Private public interface AsyncClusterConnection extends AsyncConnection
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Boolean> |
bulkLoad(TableName tableName,
List<Pair<byte[],String>> familyPaths,
byte[] row,
boolean assignSeqNum,
org.apache.hadoop.security.token.Token<?> userToken,
String bulkToken,
boolean copyFiles,
List<String> clusterIds,
boolean replicate)
Securely bulk load a list of HFiles, passing additional list of clusters ids tracking clusters
where the given bulk load has already been processed (important for bulk loading replication).
|
CompletableFuture<Void> |
cleanupBulkLoad(TableName tableName,
String bulkToken)
Clean up after finishing bulk load, no matter success or not.
|
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse> |
flush(byte[] regionName,
boolean writeFlushWALMarker)
Flush a region and get the response.
|
CompletableFuture<List<ServerName>> |
getAllBootstrapNodes(ServerName regionServer)
Get the bootstrap node list of another region server.
|
CompletableFuture<List<ServerName>> |
getLiveRegionServers(MasterAddressTracker masterAddrTracker,
int count)
Get live region servers from masters.
|
NonceGenerator |
getNonceGenerator()
Get the nonce generator for this connection.
|
CompletableFuture<RegionLocations> |
getRegionLocations(TableName tableName,
byte[] row,
boolean reload)
Return all the replicas for a region.
|
AsyncRegionServerAdmin |
getRegionServerAdmin(ServerName serverName)
Get the admin service for the given region server.
|
RpcClient |
getRpcClient()
Get the rpc client we used to communicate with other servers.
|
CompletableFuture<String> |
prepareBulkLoad(TableName tableName)
Return the token for this bulk load.
|
CompletableFuture<Void> |
replicate(RegionInfo replica,
List<WAL.Entry> entries,
int numRetries,
long rpcTimeoutNs,
long operationTimeoutNs)
Replicate wal edits to a secondary replica.
|
clearRegionLocationCache, getAdmin, getAdmin, getAdminBuilder, getAdminBuilder, getBufferedMutator, getBufferedMutator, getBufferedMutatorBuilder, getBufferedMutatorBuilder, getConfiguration, getHbck, getHbck, getRegionLocator, getTable, getTable, getTableBuilder, getTableBuilder, isClosed, toConnection
AsyncRegionServerAdmin getRegionServerAdmin(ServerName serverName)
NonceGenerator getNonceGenerator()
RpcClient getRpcClient()
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse> flush(byte[] regionName, boolean writeFlushWALMarker)
CompletableFuture<RegionLocations> getRegionLocations(TableName tableName, byte[] row, boolean reload)
CompletableFuture<String> prepareBulkLoad(TableName tableName)
CompletableFuture<Boolean> bulkLoad(TableName tableName, List<Pair<byte[],String>> familyPaths, byte[] row, boolean assignSeqNum, org.apache.hadoop.security.token.Token<?> userToken, String bulkToken, boolean copyFiles, List<String> clusterIds, boolean replicate)
tableName
- the target tablefamilyPaths
- hdfs path for the the table family dirs containg files to be loaded.row
- row key.assignSeqNum
- seq num for the event on WAL.userToken
- user token.bulkToken
- bulk load token.copyFiles
- flag for copying the loaded hfiles.clusterIds
- list of cluster ids where the given bulk load has already been processed.replicate
- flags if the bulkload is targeted for replication.CompletableFuture<Void> cleanupBulkLoad(TableName tableName, String bulkToken)
CompletableFuture<List<ServerName>> getLiveRegionServers(MasterAddressTracker masterAddrTracker, int count)
CompletableFuture<List<ServerName>> getAllBootstrapNodes(ServerName regionServer)
CompletableFuture<Void> replicate(RegionInfo replica, List<WAL.Entry> entries, int numRetries, long rpcTimeoutNs, long operationTimeoutNs)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.