Uses of Interface
org.apache.hadoop.hbase.regionserver.MemStoreSizing
Packages that use MemStoreSizing
-
Uses of MemStoreSizing in org.apache.hadoop.hbase.regionserver
Classes in org.apache.hadoop.hbase.regionserver that implement MemStoreSizingModifier and TypeClassDescriptionclassCellArrayImmutableSegment extends the API supported by aSegment, andImmutableSegment.classCellChunkImmutableSegment extends the API supported by aSegment, andImmutableSegment.classThe CompositeImmutableSegments is created as a collection of ImmutableSegments and supports the interface of a single ImmutableSegments.classCSLMImmutableSegment is an abstract class that extends the API supported by aSegment, andImmutableSegment.classImmutableSegment is an abstract class that extends the API supported by aSegment, and is not needed for aMutableSegment.classA mutable segment in memstore, specifically the active segment.(package private) classAccounting of current heap and data sizes.classThis is an abstraction of a segment maintained in a memstore, e.g., the active cell set or its snapshot.(package private) classAccounting of current heap and data sizes.Fields in org.apache.hadoop.hbase.regionserver declared as MemStoreSizingModifier and TypeFieldDescriptionstatic final MemStoreSizingMemStoreSizing.DUDprivate final MemStoreSizingHRegion.memStoreSizingprotected final MemStoreSizingSegment.memStoreSizing(package private) final MemStoreSizingHRegion.PrepareFlushResult.totalFlushableSizeMethods in org.apache.hadoop.hbase.regionserver with parameters of type MemStoreSizingModifier and TypeMethodDescriptionvoidAbstractMemStore.add(Iterable<Cell> cells, MemStoreSizing memstoreSizing) voidAbstractMemStore.add(Cell cell, MemStoreSizing memstoreSizing) voidHStore.add(Iterable<Cell> cells, MemStoreSizing memstoreSizing) Adds the specified value to the memstorevoidHStore.add(Cell cell, MemStoreSizing memstoreSizing) Adds a value to the memstorevoidMemStore.add(Iterable<Cell> cells, MemStoreSizing memstoreSizing) Write the updatesvoidMemStore.add(Cell cell, MemStoreSizing memstoreSizing) Write an updatevoidMutableSegment.add(Cell cell, boolean mslabUsed, MemStoreSizing memStoreSizing, boolean sizeAddedPreOperation) Adds the given cell into the segmentprotected voidHRegion.BatchOperation.applyFamilyMapToMemStore(Map<byte[], List<Cell>> familyMap, MemStoreSizing memstoreAccounting) Atomically apply the given map of family->edits to the memstore.private voidHRegion.applyToMemStore(HStore store, List<Cell> cells, boolean delta, MemStoreSizing memstoreAccounting) private voidHRegion.applyToMemStore(HStore store, Cell cell, MemStoreSizing memstoreAccounting) protected booleanCompactingMemStore.checkAndAddToActiveSize(MutableSegment currActive, Cell cellToAdd, MemStoreSizing memstoreSizing) Check whether anything need to be done based on the current active set size.private CellCellChunkImmutableSegment.copyCellIntoMSLAB(Cell cell, MemStoreSizing memstoreSizing) SegmentFactory.createImmutableSegment(MutableSegment segment, MemStoreSizing memstoreSizing) SegmentFactory.createImmutableSegmentByFlattening(CSLMImmutableSegment segment, CompactingMemStore.IndexType idxType, MemStoreSizing memstoreSizing, MemStoreCompactionStrategy.Action action) SegmentFactory.createMutableSegment(org.apache.hadoop.conf.Configuration conf, CellComparator comparator, MemStoreSizing memstoreSizing) protected voidAbstractMemStore.doAdd(MutableSegment currentActive, Cell cell, MemStoreSizing memstoreSizing) private voidAbstractMemStore.doAddOrUpsert(Cell cell, long readpoint, MemStoreSizing memstoreSizing, boolean doAdd) private voidAbstractMemStore.doUpsert(MutableSegment currentActive, Cell cell, long readpoint, MemStoreSizing memstoreSizing) private MutableSegmentSegmentFactory.generateMutableSegment(org.apache.hadoop.conf.Configuration conf, CellComparator comparator, MemStoreLAB memStoreLAB, MemStoreSizing memstoreSizing) private voidAbstractMemStore.internalAdd(MutableSegment currentActive, Cell toAdd, boolean mslabUsed, MemStoreSizing memstoreSizing) protected voidCompositeImmutableSegment.internalAdd(Cell cell, boolean mslabUsed, MemStoreSizing memstoreSizing, boolean sizeAddedPreOperation) protected voidSegment.internalAdd(Cell cell, boolean mslabUsed, MemStoreSizing memstoreSizing, boolean sizeAddedPreOperation) protected abstract booleanAbstractMemStore.preUpdate(MutableSegment currentActive, Cell cell, MemStoreSizing memstoreSizing) Issue any synchronization and test needed before applying the updateprotected booleanCompactingMemStore.preUpdate(MutableSegment currentActive, Cell cell, MemStoreSizing memstoreSizing) Issue any synchronization and test needed before applying the update For compacting memstore this means checking the update can increase the size without overflowprotected booleanDefaultMemStore.preUpdate(MutableSegment currentActive, Cell cell, MemStoreSizing memstoreSizing) private voidCellChunkImmutableSegment.reinitializeCellSet(int numOfCells, KeyValueScanner segmentScanner, CellSet oldCellSet, MemStoreSizing memstoreSizing, MemStoreCompactionStrategy.Action action) protected voidHRegion.restoreEdit(HStore s, Cell cell, MemStoreSizing memstoreAccounting) Used by testsprotected voidCompositeImmutableSegment.updateMetaInfo(Cell cellToAdd, boolean succ, boolean mslabUsed, MemStoreSizing memstoreSizing, boolean sizeAddedPreOperation) protected voidSegment.updateMetaInfo(Cell cellToAdd, boolean succ, boolean mslabUsed, MemStoreSizing memstoreSizing, boolean sizeAddedPreOperation) protected voidSegment.updateMetaInfo(Cell cellToAdd, boolean succ, MemStoreSizing memstoreSizing) voidAbstractMemStore.upsert(Iterable<Cell> cells, long readpoint, MemStoreSizing memstoreSizing) private voidAbstractMemStore.upsert(Cell cell, long readpoint, MemStoreSizing memstoreSizing) voidHStore.upsert(Iterable<Cell> cells, long readpoint, MemStoreSizing memstoreSizing) Adds or replaces the specified KeyValues.voidMemStore.upsert(Iterable<Cell> cells, long readpoint, MemStoreSizing memstoreSizing) Update or insert the specified cells.voidMutableSegment.upsert(Cell cell, long readpoint, MemStoreSizing memStoreSizing, boolean sizeAddedPreOperation) Constructors in org.apache.hadoop.hbase.regionserver with parameters of type MemStoreSizingModifierConstructorDescriptionprotectedCellArrayImmutableSegment(CSLMImmutableSegment segment, MemStoreSizing mss, MemStoreCompactionStrategy.Action action) ------------------------------------------------------------------------ C-tor to be used when new CellChunkImmutableSegment is built as a result of flattening of CSLMImmutableSegment The given iterator returns the Cells that "survived" the compaction.protectedCellChunkImmutableSegment(CSLMImmutableSegment segment, MemStoreSizing memstoreSizing, MemStoreCompactionStrategy.Action action) ------------------------------------------------------------------------ C-tor to be used when new CellChunkImmutableSegment is built as a result of flattening of CSLMImmutableSegment The given iterator returns the Cells that "survived" the compaction.protectedCSLMImmutableSegment(Segment segment, MemStoreSizing memstoreSizing) ------------------------------------------------------------------------ Copy C-tor to be used when new CSLMImmutableSegment is being built from a Mutable one.protectedMutableSegment(CellSet cellSet, CellComparator comparator, MemStoreLAB memStoreLAB, MemStoreSizing memstoreSizing) (package private)PrepareFlushResult(TreeMap<byte[], StoreFlushContext> storeFlushCtxs, TreeMap<byte[], List<org.apache.hadoop.fs.Path>> committedFiles, TreeMap<byte[], MemStoreSize> storeFlushableSize, long startTime, long flushSeqId, long flushedSeqId, MemStoreSizing totalFlushableSize) Constructs a successful prepare flush resultprivatePrepareFlushResult(HRegion.FlushResultImpl result, TreeMap<byte[], StoreFlushContext> storeFlushCtxs, TreeMap<byte[], List<org.apache.hadoop.fs.Path>> committedFiles, TreeMap<byte[], MemStoreSize> storeFlushableSize, long startTime, long flushSeqId, long flushedSeqId, MemStoreSizing totalFlushableSize)