static class RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter extends Object
Modifier and Type | Field and Description |
---|---|
(package private) ClusterConnection |
connection |
(package private) org.apache.hbase.thirdparty.com.google.common.cache.Cache<TableName,Boolean> |
disabledAndDroppedTables |
(package private) int |
operationTimeout |
(package private) ExecutorService |
pool |
(package private) RpcControllerFactory |
rpcControllerFactory |
(package private) RpcRetryingCallerFactory |
rpcRetryingCallerFactory |
(package private) RegionReplicaReplicationEndpoint.RegionReplicaOutputSink |
sink |
(package private) TableDescriptors |
tableDescriptors |
Constructor and Description |
---|
RegionReplicaSinkWriter(RegionReplicaReplicationEndpoint.RegionReplicaOutputSink sink,
ClusterConnection connection,
ExecutorService pool,
int operationTimeout,
TableDescriptors tableDescriptors) |
Modifier and Type | Method and Description |
---|---|
void |
append(TableName tableName,
byte[] encodedRegionName,
byte[] row,
List<WAL.Entry> entries) |
ClusterConnection connection
RpcControllerFactory rpcControllerFactory
RpcRetryingCallerFactory rpcRetryingCallerFactory
int operationTimeout
ExecutorService pool
org.apache.hbase.thirdparty.com.google.common.cache.Cache<TableName,Boolean> disabledAndDroppedTables
TableDescriptors tableDescriptors
public RegionReplicaSinkWriter(RegionReplicaReplicationEndpoint.RegionReplicaOutputSink sink, ClusterConnection connection, ExecutorService pool, int operationTimeout, TableDescriptors tableDescriptors)
public void append(TableName tableName, byte[] encodedRegionName, byte[] row, List<WAL.Entry> entries) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.