org.apache.hadoop.hbase.regionserver

Class HMobStore

java.lang.Object

org.apache.hadoop.hbase.regionserver.HStore

org.apache.hadoop.hbase.regionserver.HMobStore

All Implemented Interfaces:

ConfigurationObserver, PropagatingConfigurationObserver, HeapSize, Store, StoreConfigInformation

@InterfaceAudience.Private
public class HMobStore
extends HStore

The store implementation to save MOBs (medium objects), it extends the HStore. When a descriptor of a column family has the value "IS_MOB", it means this column family is a mob one. When a HRegion instantiate a store for this column family, the HMobStore is created. HMobStore is almost the same with the HStore except using different types of scanners. In the method of getScanner, the MobStoreScanner and MobReversedStoreScanner are returned. In these scanners, a additional seeks in the mob files should be performed after the seek to HBase is done. The store implements how we save MOBs by extending HStore. When a descriptor of a column family has the value "IS_MOB", it means this column family is a mob one. When a HRegion instantiate a store for this column family, the HMobStore is created. HMobStore is almost the same with the HStore except using different types of scanners. In the method of getScanner, the MobStoreScanner and MobReversedStoreScanner are returned. In these scanners, a additional seeks in the mob files should be performed after the seek in HBase is done.

Field Summary

Fields

Modifier and Type	Field and Description
private AtomicLong	cellsCountCompactedFromMob
private AtomicLong	cellsCountCompactedToMob
private AtomicLong	cellsSizeCompactedFromMob
private AtomicLong	cellsSizeCompactedToMob
private ColumnFamilyDescriptor	family
private org.apache.hadoop.fs.Path	homePath
private IdLock	keyLock
private static org.slf4j.Logger	LOG
private Map<String,List<org.apache.hadoop.fs.Path>>	map
private org.apache.hadoop.fs.Path	mobFamilyPath
private MobFileCache	mobFileCache
private AtomicLong	mobFlushCount
private AtomicLong	mobFlushedCellsCount
private AtomicLong	mobFlushedCellsSize
private AtomicLong	mobScanCellsCount
private AtomicLong	mobScanCellsSize
private byte[]	refCellTags

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

archiveLock, BLOCK_STORAGE_POLICY_KEY, BLOCKING_STOREFILES_KEY, blocksize, bytesPerChecksum, cacheConf, checksumType, closeCheckInterval, COMPACTCHECKER_INTERVAL_MULTIPLIER_KEY, comparator, conf, cryptoContext, DEEP_OVERHEAD, DEFAULT_BLOCK_STORAGE_POLICY, DEFAULT_BLOCKING_STOREFILE_COUNT, DEFAULT_COMPACTCHECKER_INTERVAL_MULTIPLIER, FIXED_OVERHEAD, forceMajor, lock, memstore, MEMSTORE_CLASS_NAME, region, storeEngine

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

NO_PRIORITY, PRIORITY_USER

Constructor Summary

Constructors

Constructor and Description
HMobStore(HRegion region, ColumnFamilyDescriptor family, org.apache.hadoop.conf.Configuration confParam, boolean warmup)

Method Summary

Modifier and Type	Method and Description
void	commitFile(org.apache.hadoop.fs.Path sourceFile, org.apache.hadoop.fs.Path targetPath) Commits the mob file.
StoreFileWriter	createDelFileWriterInTmp(Date date, long maxKeyCount, Compression.Algorithm compression, byte[] startKey) Creates the writer for the del file in temp directory.
protected KeyValueScanner	createScanner(Scan scan, ScanInfo scanInfo, NavigableSet<byte[]> targetCols, long readPt) Gets the MobStoreScanner or MobReversedStoreScanner.
protected StoreEngine<?,?,?,?>	createStoreEngine(HStore store, org.apache.hadoop.conf.Configuration conf, CellComparator cellComparator) Creates the mob store engine.
StoreFileWriter	createWriterInTmp(Date date, long maxKeyCount, Compression.Algorithm compression, byte[] startKey, boolean isCompaction) Creates the writer for the mob file in temp directory.
StoreFileWriter	createWriterInTmp(MobFileName mobFileName, org.apache.hadoop.fs.Path basePath, long maxKeyCount, Compression.Algorithm compression, boolean isCompaction) Creates the writer for the mob file in temp directory.
StoreFileWriter	createWriterInTmp(String date, org.apache.hadoop.fs.Path basePath, long maxKeyCount, Compression.Algorithm compression, byte[] startKey, boolean isCompaction) Creates the writer for the mob file in temp directory.
long	getCellsCountCompactedFromMob()
long	getCellsCountCompactedToMob()
long	getCellsSizeCompactedFromMob()
long	getCellsSizeCompactedToMob()
org.apache.hadoop.conf.Configuration	getConfiguration() Gets current config.
long	getMobFlushCount()
long	getMobFlushedCellsCount()
long	getMobFlushedCellsSize()
long	getMobScanCellsCount()
long	getMobScanCellsSize()
org.apache.hadoop.fs.Path	getPath() Gets the mob file path.
byte[]	getRefCellTags()
private org.apache.hadoop.fs.Path	getTempDir() Gets the temp directory.
private Cell	readCell(List<org.apache.hadoop.fs.Path> locations, String fileName, Cell search, boolean cacheMobBlocks, long readPt, boolean readEmptyValueOnMobCellMiss) Reads the cell from a mob file.
Cell	resolve(Cell reference, boolean cacheBlocks) Reads the cell from the mob file, and the read point does not count.
Cell	resolve(Cell reference, boolean cacheBlocks, long readPt, boolean readEmptyValueOnMobCellMiss) Reads the cell from the mob file.
void	updateCellsCountCompactedFromMob(long count)
void	updateCellsCountCompactedToMob(long count)
void	updateCellsSizeCompactedFromMob(long size)
void	updateCellsSizeCompactedToMob(long size)
void	updateMobFlushCount()
void	updateMobFlushedCellsCount(long count)
void	updateMobFlushedCellsSize(long size)
void	updateMobScanCellsCount(long count)
void	updateMobScanCellsSize(long size)
private void	validateMobFile(org.apache.hadoop.fs.Path path) Validates a mob file by opening and closing it.

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

add, add, addChangedReaderObserver, areWritesEnabled, assertBulkLoadHFileOk, bulkLoadHFile, bulkLoadHFile, cancelRequestedCompaction, canSplit, close, closeAndArchiveCompactedFiles, compact, compactRecentForTestingAssumingDefaultPolicy, completeCompaction, createCacheConf, createFlushContext, createStoreFileAndReader, createWriterInTmp, deleteChangedReaderObserver, deregisterChildren, determineTTLFromFamily, doCompaction, flushCache, getAvgStoreFileAge, getBlockingFileCount, getBytesPerChecksum, getCacheConfig, getChecksumType, getCloseCheckInterval, getColumnFamilyDescriptor, getColumnFamilyName, getCompactedCellsCount, getCompactedCellsSize, getCompactedFiles, getCompactedFilesCount, getCompactionCheckMultiplier, getCompactionPressure, getCompactionProgress, getCompactPriority, getComparator, getCoprocessorHost, getCurrentParallelPutCount, getDataBlockEncoder, getFileSystem, getFlushableSize, getFlushedCellsCount, getFlushedCellsSize, getFlushedOutputFileSize, getHFilesSize, getHRegion, getLastCompactSize, getMajorCompactedCellsCount, getMajorCompactedCellsSize, getMaxMemStoreTS, getMaxSequenceId, getMaxStoreFileAge, getMemStoreFlushSize, getMemStoreSize, getMinStoreFileAge, getNumHFiles, getNumReferenceFiles, getOffPeakHours, getRegionFileSystem, getRegionInfo, getScanInfo, getScanner, getScanners, getScanners, getScanners, getScanners, getSize, getSmallestReadPoint, getSnapshotSize, getSplitPoint, getStoreEngine, getStorefiles, getStorefilesCount, getStoreFileSize, getStorefilesRootLevelIndexSize, getStorefilesSize, getStoreFileTtl, getStoreHomedir, getStoreHomedir, getStoreSizeUncompressed, getTableName, getTotalStaticBloomSize, getTotalStaticIndexSize, hasReferences, hasTooManyStoreFiles, heapSize, isPrimaryReplicaStore, isSloppyMemStore, moveFileIntoPlace, needsCompaction, onConfigurationChange, postSnapshotOperation, preBulkLoadHFile, preFlushSeqIDEstimation, preSnapshotOperation, recreateScanners, refreshStoreFiles, refreshStoreFiles, registerChildren, replaceStoreFiles, replayCompactionMarker, reportArchivedFilesForQuota, requestCompaction, requestCompaction, setDataBlockEncoderInTest, setScanInfo, shouldPerformMajorCompaction, snapshot, startReplayingFromWAL, stopReplayingFromWAL, throttleCompaction, timeOfOldestEdit, toString, triggerMajorCompaction, updateSpaceQuotaAfterFileReplacement, upsert, versionsToReturn

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

mobFileCache

private MobFileCache mobFileCache

homePath

private org.apache.hadoop.fs.Path homePath

mobFamilyPath

private org.apache.hadoop.fs.Path mobFamilyPath

cellsCountCompactedToMob

private AtomicLong cellsCountCompactedToMob

cellsCountCompactedFromMob

private AtomicLong cellsCountCompactedFromMob

cellsSizeCompactedToMob

private AtomicLong cellsSizeCompactedToMob

cellsSizeCompactedFromMob

private AtomicLong cellsSizeCompactedFromMob

mobFlushCount

private AtomicLong mobFlushCount

mobFlushedCellsCount

private AtomicLong mobFlushedCellsCount

mobFlushedCellsSize

private AtomicLong mobFlushedCellsSize

mobScanCellsCount

private AtomicLong mobScanCellsCount

mobScanCellsSize

private AtomicLong mobScanCellsSize

family

private ColumnFamilyDescriptor family

map

private Map<String,List<org.apache.hadoop.fs.Path>> map

keyLock

private final IdLock keyLock

refCellTags

private final byte[] refCellTags

Constructor Detail

HMobStore

public HMobStore(HRegion region,
                 ColumnFamilyDescriptor family,
                 org.apache.hadoop.conf.Configuration confParam,
                 boolean warmup)
          throws IOException

Throws:

IOException

Method Detail

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Gets current config.

createScanner

protected KeyValueScanner createScanner(Scan scan,
                                        ScanInfo scanInfo,
                                        NavigableSet<byte[]> targetCols,
                                        long readPt)
                                 throws IOException

Gets the MobStoreScanner or MobReversedStoreScanner. In these scanners, a additional seeks in the mob files should be performed after the seek in HBase is done.

Overrides:

createScanner in class HStore

Throws:

IOException

createStoreEngine

protected StoreEngine<?,?,?,?> createStoreEngine(HStore store,
                                                 org.apache.hadoop.conf.Configuration conf,
                                                 CellComparator cellComparator)
                                          throws IOException

Creates the mob store engine.

Overrides:

createStoreEngine in class HStore

Parameters:

store - The store. An unfortunate dependency needed due to it being passed to coprocessors via the compactor.

conf - Store configuration.

cellComparator - KVComparator for storeFileManager.

Returns:

StoreEngine to use.

Throws:

IOException

getTempDir

private org.apache.hadoop.fs.Path getTempDir()

Gets the temp directory.

Returns:

The temp directory.

createWriterInTmp

public StoreFileWriter createWriterInTmp(Date date,
                                         long maxKeyCount,
                                         Compression.Algorithm compression,
                                         byte[] startKey,
                                         boolean isCompaction)
                                  throws IOException

Creates the writer for the mob file in temp directory.

Parameters:

date - The latest date of written cells.

maxKeyCount - The key count.

compression - The compression algorithm.

startKey - The start key.

isCompaction - If the writer is used in compaction.

Returns:

The writer for the mob file.

Throws:

IOException

createDelFileWriterInTmp

public StoreFileWriter createDelFileWriterInTmp(Date date,
                                                long maxKeyCount,
                                                Compression.Algorithm compression,
                                                byte[] startKey)
                                         throws IOException

Creates the writer for the del file in temp directory. The del file keeps tracking the delete markers. Its name has a suffix _del, the format is [0-9a-f]+(_del)?.

Parameters:

date - The latest date of written cells.

maxKeyCount - The key count.

compression - The compression algorithm.

startKey - The start key.

Returns:

The writer for the del file.

Throws:

IOException

createWriterInTmp

public StoreFileWriter createWriterInTmp(String date,
                                         org.apache.hadoop.fs.Path basePath,
                                         long maxKeyCount,
                                         Compression.Algorithm compression,
                                         byte[] startKey,
                                         boolean isCompaction)
                                  throws IOException

Creates the writer for the mob file in temp directory.

Parameters:

date - The date string, its format is yyyymmmdd.

basePath - The basic path for a temp directory.

maxKeyCount - The key count.

compression - The compression algorithm.

startKey - The start key.

isCompaction - If the writer is used in compaction.

Returns:

The writer for the mob file.

Throws:

IOException

createWriterInTmp

public StoreFileWriter createWriterInTmp(MobFileName mobFileName,
                                         org.apache.hadoop.fs.Path basePath,
                                         long maxKeyCount,
                                         Compression.Algorithm compression,
                                         boolean isCompaction)
                                  throws IOException

Creates the writer for the mob file in temp directory.

Parameters:

mobFileName - The mob file name.

basePath - The basic path for a temp directory.

maxKeyCount - The key count.

compression - The compression algorithm.

isCompaction - If the writer is used in compaction.

Returns:

The writer for the mob file.

Throws:

IOException

commitFile

public void commitFile(org.apache.hadoop.fs.Path sourceFile,
                       org.apache.hadoop.fs.Path targetPath)
                throws IOException

Commits the mob file.

Parameters:

sourceFile - The source file.

targetPath - The directory path where the source file is renamed to.

Throws:

IOException

validateMobFile

private void validateMobFile(org.apache.hadoop.fs.Path path)
                      throws IOException

Validates a mob file by opening and closing it.

Parameters:

path - the path to the mob file

Throws:

IOException

resolve

public Cell resolve(Cell reference,
                    boolean cacheBlocks)
             throws IOException

Reads the cell from the mob file, and the read point does not count. This is used for DefaultMobStoreCompactor where we can read empty value for the missing cell.

Parameters:

reference - The cell found in the HBase, its value is a path to a mob file.

cacheBlocks - Whether the scanner should cache blocks.

Returns:

The cell found in the mob file.

Throws:

IOException

resolve

public Cell resolve(Cell reference,
                    boolean cacheBlocks,
                    long readPt,
                    boolean readEmptyValueOnMobCellMiss)
             throws IOException

Reads the cell from the mob file.

Parameters:

reference - The cell found in the HBase, its value is a path to a mob file.

cacheBlocks - Whether the scanner should cache blocks.

readPt - the read point.

readEmptyValueOnMobCellMiss - Whether return null value when the mob file is missing or corrupt.

Returns:

The cell found in the mob file.

Throws:

IOException

readCell

private Cell readCell(List<org.apache.hadoop.fs.Path> locations,
                      String fileName,
                      Cell search,
                      boolean cacheMobBlocks,
                      long readPt,
                      boolean readEmptyValueOnMobCellMiss)
               throws IOException

Reads the cell from a mob file. The mob file might be located in different directories. 1. The working directory. 2. The archive directory. Reads the cell from the files located in both of the above directories.

Parameters:

locations - The possible locations where the mob files are saved.

fileName - The file to be read.

search - The cell to be searched.

cacheMobBlocks - Whether the scanner should cache blocks.

readPt - the read point.

readEmptyValueOnMobCellMiss - Whether return null value when the mob file is missing or corrupt.

Returns:

The found cell. Null if there's no such a cell.

Throws:

IOException

getPath

public org.apache.hadoop.fs.Path getPath()

Gets the mob file path.

Returns:

The mob file path.

updateCellsCountCompactedToMob

public void updateCellsCountCompactedToMob(long count)

getCellsCountCompactedToMob

public long getCellsCountCompactedToMob()

updateCellsCountCompactedFromMob

public void updateCellsCountCompactedFromMob(long count)

getCellsCountCompactedFromMob

public long getCellsCountCompactedFromMob()

updateCellsSizeCompactedToMob

public void updateCellsSizeCompactedToMob(long size)

getCellsSizeCompactedToMob

public long getCellsSizeCompactedToMob()

updateCellsSizeCompactedFromMob

public void updateCellsSizeCompactedFromMob(long size)

getCellsSizeCompactedFromMob

public long getCellsSizeCompactedFromMob()

updateMobFlushCount

public void updateMobFlushCount()

getMobFlushCount

public long getMobFlushCount()

updateMobFlushedCellsCount

public void updateMobFlushedCellsCount(long count)

getMobFlushedCellsCount

public long getMobFlushedCellsCount()

updateMobFlushedCellsSize

public void updateMobFlushedCellsSize(long size)

getMobFlushedCellsSize

public long getMobFlushedCellsSize()

updateMobScanCellsCount

public void updateMobScanCellsCount(long count)

getMobScanCellsCount

public long getMobScanCellsCount()

updateMobScanCellsSize

public void updateMobScanCellsSize(long size)

getMobScanCellsSize

public long getMobScanCellsSize()

getRefCellTags

public byte[] getRefCellTags()