| Package | Description |
|---|---|
| org.apache.hadoop.hbase.replication.regionserver |
| Modifier and Type | Class and Description |
|---|---|
class |
RecoveredReplicationSourceWALReader
Used by a
RecoveredReplicationSourceShipper. |
| Modifier and Type | Field and Description |
|---|---|
protected ReplicationSourceWALReader |
ReplicationSourceShipper.entryReader |
| Modifier and Type | Method and Description |
|---|---|
protected ReplicationSourceWALReader |
RecoveredReplicationSource.startNewWALReader(java.lang.String threadName,
java.lang.String walGroupId,
java.util.concurrent.PriorityBlockingQueue<Path> queue,
long startPosition) |
protected ReplicationSourceWALReader |
ReplicationSource.startNewWALReader(java.lang.String threadName,
java.lang.String walGroupId,
java.util.concurrent.PriorityBlockingQueue<Path> queue,
long startPosition) |
| Modifier and Type | Method and Description |
|---|---|
void |
ReplicationSourceShipper.setWALReader(ReplicationSourceWALReader entryReader) |