Uses of Class
org.apache.hadoop.hbase.regionserver.MutableSegment
Packages that use MutableSegment
-
Uses of MutableSegment in org.apache.hadoop.hbase.regionserver
Fields in org.apache.hadoop.hbase.regionserver declared as MutableSegmentMethods in org.apache.hadoop.hbase.regionserver that return MutableSegmentModifier and TypeMethodDescriptionSegmentFactory.createMutableSegment(org.apache.hadoop.conf.Configuration conf, CellComparator comparator, MemStoreSizing memstoreSizing) private MutableSegmentSegmentFactory.generateMutableSegment(org.apache.hadoop.conf.Configuration conf, CellComparator comparator, MemStoreLAB memStoreLAB, MemStoreSizing memstoreSizing) (package private) MutableSegmentAbstractMemStore.getActive()Methods in org.apache.hadoop.hbase.regionserver with parameters of type MutableSegmentModifier and TypeMethodDescriptionprotected booleanCompactingMemStore.checkAndAddToActiveSize(MutableSegment currActive, Cell cellToAdd, MemStoreSizing memstoreSizing) Check whether anything need to be done based on the current active set size.SegmentFactory.createImmutableSegment(MutableSegment segment, MemStoreSizing memstoreSizing) protected voidAbstractMemStore.doAdd(MutableSegment currentActive, ExtendedCell cell, MemStoreSizing memstoreSizing) private voidAbstractMemStore.doUpsert(MutableSegment currentActive, ExtendedCell cell, long readpoint, MemStoreSizing memstoreSizing) protected voidCompactingMemStore.flushInMemory(MutableSegment currActive) private voidAbstractMemStore.internalAdd(MutableSegment currentActive, ExtendedCell toAdd, boolean mslabUsed, MemStoreSizing memstoreSizing) Internal version of add() that doesn't clone Cells with the allocator, and doesn't take the lock.private ExtendedCellAbstractMemStore.maybeCloneWithAllocator(MutableSegment currentActive, 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 When a cell's size is too big (bigger than maxAlloc), it is not allocated on MSLAB.protected abstract voidAbstractMemStore.postUpdate(MutableSegment currentActive) Issue any post update synchronization and testsprotected voidCompactingMemStore.postUpdate(MutableSegment currentActive) protected voidDefaultMemStore.postUpdate(MutableSegment currentActive) protected abstract booleanAbstractMemStore.preUpdate(MutableSegment currentActive, ExtendedCell cell, MemStoreSizing memstoreSizing) Issue any synchronization and test needed before applying the updateprotected booleanCompactingMemStore.preUpdate(MutableSegment currentActive, ExtendedCell 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, ExtendedCell cell, MemStoreSizing memstoreSizing) protected voidCompactingMemStore.pushActiveToPipeline(MutableSegment currActive, boolean checkEmpty) NOTE: WhenCompactingMemStore.flushInMemory(MutableSegment)calls this method, due to concurrent writes and because we first add cell size to currActive.getDataSize and then actually add cell to currActive.cellSet, it is possible that currActive.getDataSize could not accommodate cellToAdd but currActive.cellSet is still empty if pending writes which not yet add cells to currActive.cellSet,so forCompactingMemStore.flushInMemory(MutableSegment),checkEmpty parameter is false.booleanCompactionPipeline.pushHead(MutableSegment segment) private voidCompactingMemStore.tryFlushInMemoryAndCompactingAsync(MutableSegment currActive) Try to flush the currActive in memory and submit the backgroundCompactingMemStore.InMemoryCompactionRunnabletoRegionServicesForStores.getInMemoryCompactionPool().