Package org.apache.hadoop.hbase.regionserver

Class CompositeImmutableSegment

java.lang.Object

org.apache.hadoop.hbase.regionserver.Segment

org.apache.hadoop.hbase.regionserver.ImmutableSegment

org.apache.hadoop.hbase.regionserver.CompositeImmutableSegment

All Implemented Interfaces:

MemStoreSizing

@Private
public class CompositeImmutableSegment
extends ImmutableSegment

The CompositeImmutableSegments is created as a collection of ImmutableSegments and supports the interface of a single ImmutableSegments. The CompositeImmutableSegments is planned to be used only as a snapshot, thus only relevant interfaces are supported

Field Summary

Fields

Modifier and Type	Field	Description
private long	keySize
private final List<ImmutableSegment>	segments

Fields inherited from class org.apache.hadoop.hbase.regionserver.ImmutableSegment

DEEP_OVERHEAD

Fields inherited from class org.apache.hadoop.hbase.regionserver.Segment

FIXED_OVERHEAD, memStoreSizing, minSequenceId, tagsPresent, timeRangeTracker

Fields inherited from interface org.apache.hadoop.hbase.regionserver.MemStoreSizing

DUD

Constructor Summary

Constructors

Constructor	Description
CompositeImmutableSegment(CellComparator comparator, List<ImmutableSegment> segments)

Method Summary

Modifier and Type	Method	Description
protected boolean	canBeFlattened()
void	close()	Closing a segment before it is being discarded
int	compare(Cell left, Cell right)
int	compareRows(Cell left, Cell right)
void	decScannerCount()
(package private) void	dump(org.slf4j.Logger log)	Dumps all cells of the segment into the given log
List<Segment>	getAllSegments()
int	getCellsCount()	Returns number of cells in segment
protected CellSet<ExtendedCell>	getCellSet()	Returns a set of all cells in the segment
long	getDataSize()	Returns Sum of all cell sizes.
long	getHeapSize()	Returns The heap size of this segment.
long	getMinSequenceId()
int	getNumOfSegments()
KeyValueScanner	getScanner(long readPoint)	Creates the scanner for the given read point
List<KeyValueScanner>	getScanners(long readPoint)
(package private) List<KeyValueScanner>	getSnapshotScanners()	We create a new SnapshotSegmentScanner to increase the reference count of MemStoreLABImpl used by this segment.
TimeRangeTracker	getTimeRangeTracker()
SortedSet<ExtendedCell>	headSet(ExtendedCell firstKeyOnRow)
long	incMemStoreSize(long delta, long heapOverhead, long offHeapOverhead, int cellsCount)	Updates the heap size counter of the segment by the given delta
void	incScannerCount()
protected long	indexEntrySize()
protected void	internalAdd(ExtendedCell cell, boolean mslabUsed, MemStoreSizing memstoreSizing, boolean sizeAddedPreOperation)
boolean	isEmpty()	Returns whether the segment has any cells
boolean	isTagsPresent()
Iterator<ExtendedCell>	iterator()
ExtendedCell	last()
ExtendedCell	maybeCloneWithAllocator(ExtendedCell cell, boolean forceCloneOfBigCell)	If the segment has a memory allocator the cell is being cloned to this space, and returned; otherwise the given cell is returned
protected CompositeImmutableSegment	setCellSet(CellSet cellSetOld, CellSet cellSetNew)	Setting the CellSet of the segment - used only for flat immutable segment for setting immutable CellSet after its creation in immutable segment constructor
boolean	shouldSeek(TimeRange tr, long oldestUnexpiredTS)
protected SortedSet<ExtendedCell>	tailSet(ExtendedCell firstCell)	Returns a subset of the segment cell set, which starts with the given cell
String	toString()
protected void	updateMetaInfo(ExtendedCell cellToAdd, boolean succ, boolean mslabUsed, MemStoreSizing memstoreSizing, boolean sizeAddedPreOperation)

Methods inherited from class org.apache.hadoop.hbase.regionserver.ImmutableSegment

getNumUniqueKeys

Methods inherited from class org.apache.hadoop.hbase.regionserver.Segment

compareAndSetDataSize, getCellLength, getComparator, getMemStoreLAB, getMemStoreSize, getOffHeapSize, heapSizeChange, indexEntryOffHeapSize, indexEntryOnHeapSize, offHeapSizeChange, sharedLock, sharedUnlock, updateMetaInfo, waitForUpdates

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.regionserver.MemStoreSizing

decMemStoreSize, decMemStoreSize, incMemStoreSize

Field Details

segments

private final List<ImmutableSegment> segments

keySize

private long keySize

Constructor Details

CompositeImmutableSegment

public CompositeImmutableSegment(CellComparator comparator,
 List<ImmutableSegment> segments)

Method Details

getAllSegments

public List<Segment> getAllSegments()

Overrides:

getAllSegments in class ImmutableSegment

getNumOfSegments

public int getNumOfSegments()

Overrides:

getNumOfSegments in class ImmutableSegment

isEmpty

public boolean isEmpty()

Returns whether the segment has any cells

Overrides:

isEmpty in class Segment

getCellsCount

public int getCellsCount()

Returns number of cells in segment

Specified by:

getCellsCount in interface MemStoreSizing

Overrides:

getCellsCount in class Segment

close

public void close()

Closing a segment before it is being discarded

Overrides:

close in class Segment

maybeCloneWithAllocator

public ExtendedCell maybeCloneWithAllocator(ExtendedCell cell,
 boolean forceCloneOfBigCell)

If the segment has a memory allocator the cell is being cloned to this space, and returned; otherwise the given cell is returned

Overrides:

maybeCloneWithAllocator in class Segment

Returns:

either the given cell or its clone

shouldSeek

public boolean shouldSeek(TimeRange tr,
 long oldestUnexpiredTS)

Overrides:

shouldSeek in class Segment

getScanner

public KeyValueScanner getScanner(long readPoint)

Creates the scanner for the given read point

Overrides:

getScanner in class Segment

Returns:

a scanner for the given read point

getScanners

public List<KeyValueScanner> getScanners(long readPoint)

Overrides:

getScanners in class Segment

isTagsPresent

public boolean isTagsPresent()

Overrides:

isTagsPresent in class Segment

incScannerCount

public void incScannerCount()

Overrides:

incScannerCount in class Segment

decScannerCount

public void decScannerCount()

Overrides:

decScannerCount in class Segment

setCellSet

protected CompositeImmutableSegment setCellSet(CellSet cellSetOld,
 CellSet cellSetNew)

Setting the CellSet of the segment - used only for flat immutable segment for setting immutable CellSet after its creation in immutable segment constructor

Overrides:

setCellSet in class Segment

Returns:

this object

indexEntrySize

protected long indexEntrySize()

Specified by:

indexEntrySize in class Segment

canBeFlattened

protected boolean canBeFlattened()

Specified by:

canBeFlattened in class ImmutableSegment

getDataSize

public long getDataSize()

Returns Sum of all cell sizes.

Specified by:

getDataSize in interface MemStoreSizing

Overrides:

getDataSize in class Segment

getHeapSize

public long getHeapSize()

Returns The heap size of this segment.

Specified by:

getHeapSize in interface MemStoreSizing

Overrides:

getHeapSize in class Segment

incMemStoreSize

public long incMemStoreSize(long delta,
 long heapOverhead,
 long offHeapOverhead,
 int cellsCount)

Updates the heap size counter of the segment by the given delta

Specified by:

incMemStoreSize in interface MemStoreSizing

Overrides:

incMemStoreSize in class Segment

getMinSequenceId

public long getMinSequenceId()

Overrides:

getMinSequenceId in class Segment

getTimeRangeTracker

public TimeRangeTracker getTimeRangeTracker()

Overrides:

getTimeRangeTracker in class Segment

last

public ExtendedCell last()

Overrides:

last in class Segment

iterator

public Iterator<ExtendedCell> iterator()

Overrides:

iterator in class Segment

headSet

public SortedSet<ExtendedCell> headSet(ExtendedCell firstKeyOnRow)

Overrides:

headSet in class Segment

compare

public int compare(Cell left,
 Cell right)

Overrides:

compare in class Segment

compareRows

public int compareRows(Cell left,
 Cell right)

Overrides:

compareRows in class Segment

getCellSet

protected CellSet<ExtendedCell> getCellSet()

Returns a set of all cells in the segment

Overrides:

getCellSet in class Segment

internalAdd

protected void internalAdd(ExtendedCell cell,
 boolean mslabUsed,
 MemStoreSizing memstoreSizing,
 boolean sizeAddedPreOperation)

Overrides:

internalAdd in class Segment

updateMetaInfo

protected void updateMetaInfo(ExtendedCell cellToAdd,
 boolean succ,
 boolean mslabUsed,
 MemStoreSizing memstoreSizing,
 boolean sizeAddedPreOperation)

Overrides:

updateMetaInfo in class Segment

tailSet

protected SortedSet<ExtendedCell> tailSet(ExtendedCell firstCell)

Returns a subset of the segment cell set, which starts with the given cell

Overrides:

tailSet in class Segment

Parameters:

firstCell - a cell in the segment

Returns:

a subset of the segment cell set, which starts with the given cell

dump

void dump(org.slf4j.Logger log)

Dumps all cells of the segment into the given log

Overrides:

dump in class Segment

toString

public String toString()

Overrides:

toString in class ImmutableSegment

getSnapshotScanners

List<KeyValueScanner> getSnapshotScanners()

Description copied from class: ImmutableSegment

We create a new SnapshotSegmentScanner to increase the reference count of MemStoreLABImpl used by this segment.

Overrides:

getSnapshotScanners in class ImmutableSegment