org.apache.hadoop.hbase.regionserver

Class TestHStore.MyStore

java.lang.Object

org.apache.hadoop.hbase.regionserver.HStore

org.apache.hadoop.hbase.regionserver.TestHStore.MyStore

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:

TestHStore

private static class TestHStore.MyStore
extends org.apache.hadoop.hbase.regionserver.HStore

Field Summary

Fields

Modifier and Type	Field and Description
private TestHStore.MyStoreHook	hook

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

archiveLock, BLOCK_STORAGE_POLICY_KEY, BLOCKING_STOREFILES_KEY, COMPACTCHECKER_INTERVAL_MULTIPLIER_KEY, conf, DEEP_OVERHEAD, DEFAULT_BLOCK_STORAGE_POLICY, DEFAULT_BLOCKING_STOREFILE_COUNT, DEFAULT_COMPACTCHECKER_INTERVAL_MULTIPLIER, FIXED_OVERHEAD, forceMajor, memstore, MEMSTORE_CLASS_NAME, storeEngine

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

NO_PRIORITY, PRIORITY_USER

Constructor Summary

Constructors

Constructor and Description
MyStore(org.apache.hadoop.hbase.regionserver.HRegion region, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor family, org.apache.hadoop.conf.Configuration confParam, TestHStore.MyStoreHook hook, boolean switchToPread)

Method Summary

Modifier and Type	Method and Description
List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>	getScanners(List<org.apache.hadoop.hbase.regionserver.HStoreFile> files, boolean cacheBlocks, boolean usePread, boolean isCompaction, org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher, byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow, long readPt, boolean includeMemstoreScanner)
long	getSmallestReadPoint()

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

add, add, addChangedReaderObserver, areWritesEnabled, assertBulkLoadHFileOk, bulkLoadHFile, bulkLoadHFile, cancelRequestedCompaction, canSplit, close, closeAndArchiveCompactedFiles, compact, createCacheConf, createFlushContext, createScanner, createStoreEngine, deleteChangedReaderObserver, deregisterChildren, determineTTLFromFamily, doCompaction, finishCompactionRequest, flushCache, getAvgStoreFileAge, getBlockingFileCount, getBloomFilterEligibleRequestsCount, getBloomFilterNegativeResultsCount, getBloomFilterRequestsCount, getCacheConfig, 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, getReadOnlyConfiguration, getRegionFileSystem, getRegionInfo, getScanInfo, getScanner, getScanners, getScanners, getScanners, getSize, getSnapshotSize, getSplitPoint, getStoreContext, getStoreEngine, getStorefiles, getStoreFilesBeingWritten, getStorefilesCount, getStoreFileSize, getStorefilesRootLevelIndexSize, getStorefilesSize, getStoreFileTtl, getStoreRefCount, getStoreSizeUncompressed, getTableName, getTotalStaticBloomSize, getTotalStaticIndexSize, hasReferences, hasTooManyStoreFiles, heapSize, isPrimaryReplicaStore, isSloppyMemStore, needsCompaction, onConfigurationChange, postSnapshotOperation, preBulkLoadHFile, preFlushSeqIDEstimation, preSnapshotOperation, recreateScanners, refreshStoreFiles, refreshStoreFiles, refreshStoreSizeAndTotalBytes, registerChildren, replaceStoreFiles, replayCompactionMarker, reportArchivedFilesForQuota, requestCompaction, requestCompaction, setDataBlockEncoderInTest, setScanInfo, shouldPerformMajorCompaction, startReplayingFromWAL, stopReplayingFromWAL, throttleCompaction, timeOfOldestEdit, toString, triggerMajorCompaction, tryCommitRecoveredHFile, updateCompactedMetrics, updateMetricsStore, updateSpaceQuotaAfterFileReplacement, upsert, versionsToReturn

Methods inherited from class java.lang.Object

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

Field Detail

hook

private final TestHStore.MyStoreHook hook

Constructor Detail

MyStore

MyStore(org.apache.hadoop.hbase.regionserver.HRegion region,
        org.apache.hadoop.hbase.client.ColumnFamilyDescriptor family,
        org.apache.hadoop.conf.Configuration confParam,
        TestHStore.MyStoreHook hook,
        boolean switchToPread)
 throws IOException

Throws:

IOException

Method Detail

getScanners

public List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> getScanners(List<org.apache.hadoop.hbase.regionserver.HStoreFile> files,
                                                                              boolean cacheBlocks,
                                                                              boolean usePread,
                                                                              boolean isCompaction,
                                                                              org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher,
                                                                              byte[] startRow,
                                                                              boolean includeStartRow,
                                                                              byte[] stopRow,
                                                                              boolean includeStopRow,
                                                                              long readPt,
                                                                              boolean includeMemstoreScanner)
                                                                       throws IOException

Overrides:

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

Throws:

IOException

getSmallestReadPoint

public long getSmallestReadPoint()

Specified by:

getSmallestReadPoint in interface org.apache.hadoop.hbase.regionserver.Store

Overrides:

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