Uses of Class
org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch

Packages that use WALEntryBatch

Package	Description
org.apache.hadoop.hbase.replication.regionserver

Uses of WALEntryBatch in org.apache.hadoop.hbase.replication.regionserver

Fields in org.apache.hadoop.hbase.replication.regionserver declared as WALEntryBatch

Modifier and Type	Field	Description
static final WALEntryBatch	WALEntryBatch.NO_MORE_DATA

Fields in org.apache.hadoop.hbase.replication.regionserver with type parameters of type WALEntryBatch

Modifier and Type	Field	Description
(package private) final BlockingQueue<WALEntryBatch>	ReplicationSourceWALReader.entryBatchQueue

Methods in org.apache.hadoop.hbase.replication.regionserver that return WALEntryBatch

Modifier and Type	Method	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

Methods in org.apache.hadoop.hbase.replication.regionserver with parameters of type WALEntryBatch

Modifier and Type	Method	Description
(package private) boolean	ReplicationSourceManager.acquireWALEntryBufferQuota(WALEntryBatch walEntryBatch, WAL.Entry entry)	Acquire the buffer quota for WAL.Entry which is added to WALEntryBatch.
protected final boolean	ReplicationSourceWALReader.addEntryToBatch(WALEntryBatch batch, WAL.Entry entry)
default void	ReplicationSourceInterface.logPositionAndCleanOldLogs(WALEntryBatch entryBatch)	Log the current position to storage.
void	ReplicationSourceManager.logPositionAndCleanOldLogs(ReplicationSourceInterface source, WALEntryBatch entryBatch)	This method will log the current position to storage.
protected void	ReplicationSourceWALReader.readWALEntries(WALEntryStream entryStream, WALEntryBatch batch)
protected void	SerialReplicationSourceWALReader.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)