org.apache.hadoop.hbase.mob.compactions

Class PartitionedMobCompactionRequest.CompactionPartition

java.lang.Object

org.apache.hadoop.hbase.mob.compactions.PartitionedMobCompactionRequest.CompactionPartition

Enclosing class:

PartitionedMobCompactionRequest

protected static class PartitionedMobCompactionRequest.CompactionPartition
extends Object

The partition in the mob compaction. The mob files that have the same start key and date in their names belong to the same partition.

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	endKey
private List<org.apache.hadoop.fs.FileStatus>	files
private PartitionedMobCompactionRequest.CompactionPartitionId	partitionId
private byte[]	startKey

Constructor Summary

Constructors

Constructor and Description
CompactionPartition(PartitionedMobCompactionRequest.CompactionPartitionId partitionId)

Method Summary

Modifier and Type	Method and Description
void	addFile(org.apache.hadoop.fs.FileStatus file)
byte[]	getEndKey()
int	getFileCount()
PartitionedMobCompactionRequest.CompactionPartitionId	getPartitionId()
byte[]	getStartKey()
List<org.apache.hadoop.fs.FileStatus>	listFiles()
void	setEndKey(byte[] endKey) Set end key of this partition, only if the input endKey is greater than the current end key.
void	setStartKey(byte[] startKey) Set start key of this partition, only if the input startKey is less than the current start key.

Methods inherited from class java.lang.Object

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

Field Detail

files

private List<org.apache.hadoop.fs.FileStatus> files

partitionId

private PartitionedMobCompactionRequest.CompactionPartitionId partitionId

startKey

private byte[] startKey

endKey

private byte[] endKey

Constructor Detail

CompactionPartition

public CompactionPartition(PartitionedMobCompactionRequest.CompactionPartitionId partitionId)

Method Detail

getPartitionId

public PartitionedMobCompactionRequest.CompactionPartitionId getPartitionId()

addFile

public void addFile(org.apache.hadoop.fs.FileStatus file)

listFiles

public List<org.apache.hadoop.fs.FileStatus> listFiles()

getFileCount

public int getFileCount()

getStartKey

public byte[] getStartKey()

setStartKey

public void setStartKey(byte[] startKey)

Set start key of this partition, only if the input startKey is less than the current start key.

getEndKey

public byte[] getEndKey()

setEndKey

public void setEndKey(byte[] endKey)

Set end key of this partition, only if the input endKey is greater than the current end key.