org.apache.hadoop.hbase.replication.regionserver

Class WALEntryBatch

java.lang.Object

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

@InterfaceAudience.Private
class 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 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 WALEntryBatch	NO_MORE_DATA
private List<Pair<WAL.Entry,Long>>	walEntriesWithSize

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 entrySize)
(package private) static WALEntryBatch	endOfFile(org.apache.hadoop.fs.Path lastWalPath)
long	getHeapSize()
Map<String,Long>	getLastSeqIds()
org.apache.hadoop.fs.Path	getLastWalPath()
long	getLastWalPosition()
int	getNbEntries()
int	getNbHFiles()
int	getNbOperations()
int	getNbRowKeys()
List<WAL.Entry>	getWalEntries()
List<Pair<WAL.Entry,Long>>	getWalEntriesWithSize()
void	incrementHeapSize(long increment)
void	incrementNbHFiles(int increment)
void	incrementNbRowKeys(int increment)
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 Detail

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

Constructor Detail

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 Detail

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)

toString

public String toString()

Overrides:

toString in class Object