Package org.apache.hadoop.hbase.replication.regionserver

Class RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter

Enclosing class:

RegionReplicaReplicationEndpoint

static class RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter
extends Object

Field Summary

Fields

Modifier and Type	Field	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 Summary

Constructors

Constructor	Description
RegionReplicaSinkWriter(RegionReplicaReplicationEndpoint.RegionReplicaOutputSink sink, ClusterConnection connection, ExecutorService pool, int operationTimeout, TableDescriptors tableDescriptors)

Method Summary

Modifier and Type	Method	Description
void	append(TableName tableName, byte[] encodedRegionName, byte[] row, List<WAL.Entry> entries)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

sink

RegionReplicaReplicationEndpoint.RegionReplicaOutputSink sink

connection

ClusterConnection connection

rpcControllerFactory

RpcControllerFactory rpcControllerFactory

rpcRetryingCallerFactory

RpcRetryingCallerFactory rpcRetryingCallerFactory

operationTimeout

int operationTimeout

pool

ExecutorService pool

disabledAndDroppedTables

org.apache.hbase.thirdparty.com.google.common.cache.Cache<TableName,Boolean> disabledAndDroppedTables

tableDescriptors

TableDescriptors tableDescriptors

Constructor Details

RegionReplicaSinkWriter

public RegionReplicaSinkWriter(RegionReplicaReplicationEndpoint.RegionReplicaOutputSink sink,
 ClusterConnection connection,
 ExecutorService pool,
 int operationTimeout,
 TableDescriptors tableDescriptors)

Method Details

append

public void append(TableName tableName,
 byte[] encodedRegionName,
 byte[] row,
 List<WAL.Entry> entries)
            throws IOException

Throws:

IOException