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

@InterfaceAudience.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 and Description
private long	keySize
private 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 and Description
CompositeImmutableSegment(CellComparator comparator, List<ImmutableSegment> segments)

Method Summary

Modifier and Type	Method and 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()
protected CellSet	getCellSet()
long	getDataSize()
long	getHeapSize()
long	getMinSequenceId()
int	getNumOfSegments()
KeyValueScanner	getScanner(long readPoint) Creates the scanner for the given read point
KeyValueScanner	getScanner(long readPoint, long order) Creates the scanner for the given read point, and a specific order in a list
List<KeyValueScanner>	getScanners(long readPoint, long order)
(package private) List<KeyValueScanner>	getSnapshotScanners()
TimeRangeTracker	getTimeRangeTracker()
SortedSet<Cell>	headSet(Cell 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(Cell cell, boolean mslabUsed, MemStoreSizing memstoreSizing)
boolean	isEmpty()
boolean	isTagsPresent()
Iterator<Cell>	iterator()
Cell	last()
Cell	maybeCloneWithAllocator(Cell 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<Cell>	tailSet(Cell firstCell) Returns a subset of the segment cell set, which starts with the given cell
String	toString()
protected void	updateMetaInfo(Cell cellToAdd, boolean succ, boolean mslabUsed, MemStoreSizing memstoreSizing)

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

getNumUniqueKeys

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

getCellLength, getComparator, getMemStoreLAB, getMemStoreSize, getOffHeapSize, heapSizeChange, indexEntryOffHeapSize, indexEntryOnHeapSize, offHeapSizeChange, updateMetaInfo

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 Detail

segments

private final List<ImmutableSegment> segments

keySize

private long keySize

Constructor Detail

CompositeImmutableSegment

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

Method Detail

getAllSegments

public List<Segment> getAllSegments()

Overrides:

getAllSegments in class ImmutableSegment

getNumOfSegments

public int getNumOfSegments()

Overrides:

getNumOfSegments in class ImmutableSegment

isEmpty

public boolean isEmpty()

Overrides:

isEmpty in class Segment

Returns:

whether the segment has any cells

getCellsCount

public int getCellsCount()

Specified by:

getCellsCount in interface MemStoreSizing

Overrides:

getCellsCount in class Segment

Returns:

number of cells in segment

close

public void close()

Closing a segment before it is being discarded

Overrides:

close in class Segment

maybeCloneWithAllocator

public Cell maybeCloneWithAllocator(Cell 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

getScanner

public KeyValueScanner getScanner(long readPoint,
                                  long order)

Creates the scanner for the given read point, and a specific order in a list

Overrides:

getScanner in class Segment

Returns:

a scanner for the given read point

getScanners

public List<KeyValueScanner> getScanners(long readPoint,
                                         long order)

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()

Specified by:

getDataSize in interface MemStoreSizing

Overrides:

getDataSize in class Segment

Returns:

Sum of all cell sizes.

getHeapSize

public long getHeapSize()

Specified by:

getHeapSize in interface MemStoreSizing

Overrides:

getHeapSize in class Segment

Returns:

The heap size of this 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

Returns:

The new dataSize ONLY as a convenience

getMinSequenceId

public long getMinSequenceId()

Overrides:

getMinSequenceId in class Segment

getTimeRangeTracker

public TimeRangeTracker getTimeRangeTracker()

Overrides:

getTimeRangeTracker in class Segment

last

public Cell last()

Overrides:

last in class Segment

iterator

public Iterator<Cell> iterator()

Overrides:

iterator in class Segment

headSet

public SortedSet<Cell> headSet(Cell 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 getCellSet()

Overrides:

getCellSet in class Segment

Returns:

a set of all cells in the segment

internalAdd

protected void internalAdd(Cell cell,
                           boolean mslabUsed,
                           MemStoreSizing memstoreSizing)

Overrides:

internalAdd in class Segment

updateMetaInfo

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

Overrides:

updateMetaInfo in class Segment

tailSet

protected SortedSet<Cell> tailSet(Cell 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()

Overrides:

getSnapshotScanners in class ImmutableSegment