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

Class WALEntryBatch

java.lang.Object

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

@Private
class WALEntryBatch
extends Object

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

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	endOfFile
private long	heapSize
private Map<String,Long>	lastSeqIds
private org.apache.hadoop.fs.Path	lastWalPath
private long	lastWalPosition
private int	nbHFiles
private int	nbRowKeys
static final WALEntryBatch	NO_MORE_DATA
private long	usedBufferSize
private List<Pair<WAL.Entry,Long>>	walEntriesWithSize

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addEntry(WAL.Entry entry, long entrySize)
(package private) static WALEntryBatch	endOfFile(org.apache.hadoop.fs.Path lastWalPath)
(package private) static long	getEntrySizeExcludeBulkLoad(WAL.Entry entry)
long	getHeapSize()	Returns the heap size of this batch
Map<String,Long>	getLastSeqIds()	Returns the last sequenceid for each region if the table has serial-replication scope
org.apache.hadoop.fs.Path	getLastWalPath()	Returns the path of the last WAL that was read.
long	getLastWalPosition()	Returns the position in the last WAL that was read.
int	getNbEntries()
int	getNbHFiles()	Returns the number of HFiles in this batch
int	getNbOperations()	Returns total number of operations in this batch
int	getNbRowKeys()	Returns the number of distinct row keys in this batch
long	getUsedBufferSize()
List<WAL.Entry>	getWalEntries()	Returns the WAL Entries.
List<Pair<WAL.Entry,Long>>	getWalEntriesWithSize()	Returns the WAL Entries.
void	incrementHeapSize(long increment)
void	incrementNbHFiles(int increment)
void	incrementNbRowKeys(int increment)
long	incrementUsedBufferSize(WAL.Entry entry)
boolean	isEndOfFile()
void	setEndOfFile(boolean endOfFile)
void	setLastSeqId(String region, long sequenceId)
void	setLastWalPath(org.apache.hadoop.fs.Path lastWalPath)
void	setLastWalPosition(long lastWalPosition)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

NO_MORE_DATA

public static final WALEntryBatch NO_MORE_DATA

walEntriesWithSize

private List<Pair<WAL.Entry,Long>> walEntriesWithSize

lastWalPath

private org.apache.hadoop.fs.Path lastWalPath

lastWalPosition

private long lastWalPosition

nbRowKeys

private int nbRowKeys

nbHFiles

private int nbHFiles

heapSize

private long heapSize

lastSeqIds

private Map<String,Long> lastSeqIds

endOfFile

private boolean endOfFile

usedBufferSize

private long usedBufferSize

Constructor Details

WALEntryBatch

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

Parameters:

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

Method Details

endOfFile

static WALEntryBatch endOfFile(org.apache.hadoop.fs.Path lastWalPath)

addEntry

public void addEntry(WAL.Entry entry,
 long entrySize)

getWalEntries

public List<WAL.Entry> getWalEntries()

Returns the WAL Entries.

getWalEntriesWithSize

public List<Pair<WAL.Entry,Long>> getWalEntriesWithSize()

Returns the WAL Entries.

getLastWalPath

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

Returns the path of the last WAL that was read.

setLastWalPath

public void setLastWalPath(org.apache.hadoop.fs.Path lastWalPath)

getLastWalPosition

public long getLastWalPosition()

Returns the position in the last WAL that was read.

setLastWalPosition

public void setLastWalPosition(long lastWalPosition)

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

getLastSeqIds

public Map<String,Long> getLastSeqIds()

Returns the last sequenceid for each region if the table has serial-replication scope

isEndOfFile

public boolean isEndOfFile()

setEndOfFile

public void setEndOfFile(boolean endOfFile)

incrementNbRowKeys

public void incrementNbRowKeys(int increment)

incrementNbHFiles

public void incrementNbHFiles(int increment)

incrementHeapSize

public void incrementHeapSize(long increment)

setLastSeqId

public void setLastSeqId(String region,
 long sequenceId)

incrementUsedBufferSize

public long incrementUsedBufferSize(WAL.Entry entry)

getUsedBufferSize

public long getUsedBufferSize()

toString

public String toString()

Overrides:

toString in class Object

getEntrySizeExcludeBulkLoad

static long getEntrySizeExcludeBulkLoad(WAL.Entry entry)