Package | Description |
---|---|
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<ReplicationSourceWALReader.WALEntryBatch> |
ReplicationSourceWALReader.entryBatchQueue |
Modifier and Type | Method and Description |
---|---|
private ReplicationSourceWALReader.WALEntryBatch |
ReplicationSourceWALReader.readWALEntries(WALEntryStream entryStream) |
ReplicationSourceWALReader.WALEntryBatch |
ReplicationSourceWALReader.take()
Retrieves the next batch of WAL entries from the queue, waiting up to the specified time for a
batch to become available
|
Modifier and Type | Method and Description |
---|---|
protected void |
RecoveredReplicationSourceWALReader.handleEmptyWALEntryBatch(ReplicationSourceWALReader.WALEntryBatch batch,
org.apache.hadoop.fs.Path currentPath) |
protected void |
ReplicationSourceWALReader.handleEmptyWALEntryBatch(ReplicationSourceWALReader.WALEntryBatch batch,
org.apache.hadoop.fs.Path currentPath) |
protected void |
ReplicationSourceShipper.shipEdits(ReplicationSourceWALReader.WALEntryBatch entryBatch)
Do the shipping logic
|
private void |
ReplicationSourceWALReader.updateBatchStats(ReplicationSourceWALReader.WALEntryBatch batch,
WAL.Entry entry,
long entryPosition,
long entrySize) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.