org.apache.hadoop.hbase.replication.regionserver

Class ReplicationSourceWALReader.WALEntryBatch

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader.WALEntryBatch

Enclosing class:

ReplicationSourceWALReader

static class ReplicationSourceWALReader.WALEntryBatch
extends Object

Holds a batch of WAL entries to replicate, along with some statistics

Field Summary

Fields

Modifier and Type	Field and Description
private long	heapSize
private org.apache.hadoop.fs.Path	lastWalPath
private long	lastWalPosition
private int	nbHFiles
private int	nbRowKeys
private List<WAL.Entry>	walEntries

Constructor Summary

Constructors

Constructor and Description
WALEntryBatch(int maxNbEntries, org.apache.hadoop.fs.Path lastWalPath)

Method Summary

Modifier and Type	Method and Description
void	addEntry(WAL.Entry entry)
long	getHeapSize()
org.apache.hadoop.fs.Path	getLastWalPath()
long	getLastWalPosition()
int	getNbEntries()
int	getNbHFiles()
int	getNbOperations()
int	getNbRowKeys()
List<WAL.Entry>	getWalEntries()
private void	incrementHeapSize(long increment)
private void	incrementNbHFiles(int increment)
private void	incrementNbRowKeys(int increment)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

walEntries

private List<WAL.Entry> walEntries

lastWalPath

private org.apache.hadoop.fs.Path lastWalPath

lastWalPosition

private long lastWalPosition

nbRowKeys

private int nbRowKeys

nbHFiles

private int nbHFiles

heapSize

private long heapSize

Constructor Detail

WALEntryBatch

WALEntryBatch(int maxNbEntries,
              org.apache.hadoop.fs.Path lastWalPath)

Parameters:

walEntries -

lastWalPath - Path of the WAL the last entry in this batch was read from

lastWalPosition - Position in the WAL the last entry in this batch was read from

Method Detail

addEntry

public void addEntry(WAL.Entry entry)

getWalEntries

public List<WAL.Entry> getWalEntries()

Returns:

the WAL Entries.

getLastWalPath

public org.apache.hadoop.fs.Path getLastWalPath()

Returns:

the path of the last WAL that was read.

getLastWalPosition

public long getLastWalPosition()

Returns:

the position in the last WAL that was read.

getNbEntries

public int getNbEntries()

getNbRowKeys

public int getNbRowKeys()

Returns:

the number of distinct row keys in this batch

getNbHFiles

public int getNbHFiles()

Returns:

the number of HFiles in this batch

getNbOperations

public int getNbOperations()

Returns:

total number of operations in this batch

getHeapSize

public long getHeapSize()

Returns:

the heap size of this batch

incrementNbRowKeys

private void incrementNbRowKeys(int increment)

incrementNbHFiles

private void incrementNbHFiles(int increment)

incrementHeapSize

private void incrementHeapSize(long increment)