Package | Description |
---|---|
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Field and Description |
---|---|
static WALEntryBatch |
WALEntryBatch.NO_MORE_DATA |
Modifier and Type | Field and Description |
---|---|
(package private) BlockingQueue<WALEntryBatch> |
ReplicationSourceWALReader.entryBatchQueue |
Modifier and Type | Method and Description |
---|---|
private WALEntryBatch |
ReplicationSourceWALReader.createBatch(WALEntryStream entryStream) |
(package private) static WALEntryBatch |
WALEntryBatch.endOfFile(org.apache.hadoop.fs.Path lastWalPath) |
WALEntryBatch |
ReplicationSourceWALReader.poll(long timeout) |
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 |
---|---|
(package private) boolean |
ReplicationSourceManager.acquireWALEntryBufferQuota(WALEntryBatch walEntryBatch,
WAL.Entry entry)
Acquire the buffer quota for
WAL.Entry which is added to WALEntryBatch . |
protected boolean |
ReplicationSourceWALReader.addEntryToBatch(WALEntryBatch batch,
WAL.Entry entry) |
void |
ReplicationSourceManager.logPositionAndCleanOldLogs(ReplicationSourceInterface source,
WALEntryBatch entryBatch)
This method will log the current position to storage.
|
default void |
ReplicationSourceInterface.logPositionAndCleanOldLogs(WALEntryBatch entryBatch)
Log the current position to storage.
|
protected void |
SerialReplicationSourceWALReader.readWALEntries(WALEntryStream entryStream,
WALEntryBatch batch) |
protected void |
ReplicationSourceWALReader.readWALEntries(WALEntryStream entryStream,
WALEntryBatch batch) |
(package private) long |
ReplicationSourceManager.releaseWALEntryBatchBufferQuota(WALEntryBatch walEntryBatch)
To release the buffer quota of
WALEntryBatch which acquired by
ReplicationSourceManager.acquireWALEntryBufferQuota(org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch, org.apache.hadoop.hbase.wal.WAL.Entry) . |
private void |
SerialReplicationSourceWALReader.removeEntryFromStream(WALEntryStream entryStream,
WALEntryBatch batch) |
private void |
ReplicationSourceShipper.shipEdits(WALEntryBatch entryBatch)
Do the shipping logic
|
private void |
ReplicationSourceWALReader.updateBatchStats(WALEntryBatch batch,
WAL.Entry entry,
long entrySize) |
private boolean |
ReplicationSourceShipper.updateLogPosition(WALEntryBatch batch) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.