Package | Description |
---|---|
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Class and Description |
---|---|
class |
RecoveredReplicationSource
Class that handles the recovered source of a replication stream, which is transfered from
another dead region server.
|
Constructor and Description |
---|
RecoveredReplicationSourceWALReader(FileSystem fs,
Configuration conf,
java.util.concurrent.PriorityBlockingQueue<Path> logQueue,
long startPosition,
WALEntryFilter filter,
ReplicationSource source) |
ReplicationSourceWALReader(FileSystem fs,
Configuration conf,
java.util.concurrent.PriorityBlockingQueue<Path> logQueue,
long startPosition,
WALEntryFilter filter,
ReplicationSource source)
Creates a reader worker for a given WAL queue.
|