org.apache.hadoop.hbase.replication.regionserver

Class RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter

java.lang.Object

org.apache.hadoop.hbase.wal.WALSplitter.SinkWriter

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

Enclosing class:

RegionReplicaReplicationEndpoint

static class RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter
extends WALSplitter.SinkWriter

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

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

Constructor Detail

RegionReplicaSinkWriter

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

Method Detail

append

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

Throws:

IOException