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.
|
Modifier and Type | Field and Description |
---|---|
private ReplicationSource |
ReplicationSourceWALReader.source |
Constructor and Description |
---|
RecoveredReplicationSourceWALReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.conf.Configuration conf,
PriorityBlockingQueue<org.apache.hadoop.fs.Path> logQueue,
long startPosition,
WALEntryFilter filter,
ReplicationSource source) |
ReplicationSourceWALReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.conf.Configuration conf,
PriorityBlockingQueue<org.apache.hadoop.fs.Path> logQueue,
long startPosition,
WALEntryFilter filter,
ReplicationSource source)
Creates a reader worker for a given WAL queue.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.