org.apache.hadoop.hbase.regionserver

Class TestHRegion.HStoreForTesting

java.lang.Object

org.apache.hadoop.hbase.regionserver.HStore

org.apache.hadoop.hbase.regionserver.TestHRegion.HStoreForTesting

All Implemented Interfaces:

org.apache.hadoop.hbase.conf.ConfigurationObserver, org.apache.hadoop.hbase.conf.PropagatingConfigurationObserver, org.apache.hadoop.hbase.io.HeapSize, org.apache.hadoop.hbase.regionserver.Store, org.apache.hadoop.hbase.regionserver.StoreConfigInformation

Enclosing class:

TestHRegion

public static class TestHRegion.HStoreForTesting
extends org.apache.hadoop.hbase.regionserver.HStore

HStoreForTesting is merely the same as HStore, the difference is in the doCompaction method of HStoreForTesting there is a checkpoint "hbase.hstore.compaction.complete" which doesn't let hstore compaction complete. In the former edition, this config is set in HStore class inside compact method, though this is just for testing, otherwise it doesn't do any help. In HBASE-8518, we try to get rid of all "hbase.hstore.compaction.complete" config (except for testing code).

Field Summary

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

Modifier	Constructor and Description
protected	HStoreForTesting(org.apache.hadoop.hbase.regionserver.HRegion region, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor family, org.apache.hadoop.conf.Configuration confParam, boolean warmup)

Method Summary

Modifier and Type	Method and Description
protected List<org.apache.hadoop.hbase.regionserver.HStoreFile>	doCompaction(org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl cr, Collection<org.apache.hadoop.hbase.regionserver.HStoreFile> filesToCompact, org.apache.hadoop.hbase.security.User user, long compactionStartTime, List<org.apache.hadoop.fs.Path> newFiles)

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, createScanner, createStoreEngine, createStoreFileAndReader, createWriterInTmp, createWriterInTmp, deleteChangedReaderObserver, deregisterChildren, determineTTLFromFamily, 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, getMaxCompactedStoreFileRefCount, getMaxMemStoreTS, getMaxSequenceId, getMaxStoreFileAge, getMemStoreFlushSize, getMemstoreOnlyRowReadsCount, getMemStoreSize, getMinStoreFileAge, getMixedRowReadsCount, getNumHFiles, getNumReferenceFiles, getOffPeakHours, getRegionFileSystem, getRegionInfo, getScanInfo, getScanner, getScanners, getScanners, getScanners, getScanners, getSize, getSmallestReadPoint, getSnapshotSize, getSplitPoint, getStoreEngine, getStorefiles, getStorefilesCount, getStoreFileSize, getStorefilesRootLevelIndexSize, getStorefilesSize, getStoreFileTtl, getStoreHomedir, getStoreHomedir, getStoreRefCount, 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, tryCommitRecoveredHFile, updateMetricsStore, updateSpaceQuotaAfterFileReplacement, upsert, versionsToReturn

Methods inherited from class java.lang.Object

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

Constructor Detail

HStoreForTesting

protected HStoreForTesting(org.apache.hadoop.hbase.regionserver.HRegion region,
                           org.apache.hadoop.hbase.client.ColumnFamilyDescriptor family,
                           org.apache.hadoop.conf.Configuration confParam,
                           boolean warmup)
                    throws IOException

Throws:

IOException

Method Detail

doCompaction

protected List<org.apache.hadoop.hbase.regionserver.HStoreFile> doCompaction(org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl cr,
                                                                             Collection<org.apache.hadoop.hbase.regionserver.HStoreFile> filesToCompact,
                                                                             org.apache.hadoop.hbase.security.User user,
                                                                             long compactionStartTime,
                                                                             List<org.apache.hadoop.fs.Path> newFiles)
                                                                      throws IOException

Overrides:

doCompaction in class org.apache.hadoop.hbase.regionserver.HStore

Throws:

IOException