RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter (Apache HBase 1.2.12 API)

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) 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 and Description
`RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter(RegionReplicaReplicationEndpoint.RegionReplicaOutputSink sink, ClusterConnection connection, ExecutorService pool, int operationTimeout, TableDescriptors tableDescriptors)`

Method Summary

Methods
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

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

Field Detail

sink

RegionReplicaReplicationEndpoint.RegionReplicaOutputSink sink

connection
```
ClusterConnection connection
```

rpcControllerFactory

RpcControllerFactory rpcControllerFactory

rpcRetryingCallerFactory

RpcRetryingCallerFactory rpcRetryingCallerFactory

operationTimeout
```
int operationTimeout
```

pool
```
ExecutorService pool
```

disabledAndDroppedTables

com.google.common.cache.Cache<TableName,Boolean> disabledAndDroppedTables

tableDescriptors
```
TableDescriptors tableDescriptors
```

Constructor Detail

RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter

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

Method Detail

append

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

Throws:: IOException

Class RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

sink

connection

rpcControllerFactory

rpcRetryingCallerFactory

operationTimeout

pool

disabledAndDroppedTables

tableDescriptors

Constructor Detail

RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter

Method Detail

append