org.apache.hadoop.hbase

Class TestIOFencing.CompactionBlockerRegion

java.lang.Object

org.apache.hadoop.hbase.regionserver.HRegion

org.apache.hadoop.hbase.TestIOFencing.CompactionBlockerRegion

All Implemented Interfaces:

ConfigurationObserver, PropagatingConfigurationObserver, HeapSize, Region

Direct Known Subclasses:

TestIOFencing.BlockCompactionsInCompletionRegion, TestIOFencing.BlockCompactionsInPrepRegion

Enclosing class:

TestIOFencing

public abstract static class TestIOFencing.CompactionBlockerRegion
extends HRegion

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.HRegion

HRegion.FlushResultImpl, HRegion.RowLockImpl

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.regionserver.Region

Region.BulkLoadListener, Region.FlushResult, Region.Operation, Region.RowLock

Field Summary

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

conf, DEEP_OVERHEAD, DEFAULT_CACHE_FLUSH_INTERVAL, DEFAULT_FLUSH_PER_CHANGES, FIXED_OVERHEAD, lastReplayedCompactionSeqId, lastReplayedOpenRegionSeqId, LOAD_CFS_ON_DEMAND_CONFIG_KEY, LOG, MAX_FLUSH_PER_CHANGES, MEMSTORE_FLUSH_PER_CHANGES, MEMSTORE_PERIODIC_FLUSH_INTERVAL, memstoreSize, META_CACHE_FLUSH_INTERVAL, stores

Constructor Summary

Constructors

Constructor and Description
CompactionBlockerRegion(Path tableDir, WAL log, FileSystem fs, Configuration confParam, HRegionInfo info, HTableDescriptor htd, RegionServerServices rsServices)

Method Summary

Modifier and Type	Method and Description
void	allowCompactions()
boolean	compact(CompactionContext compaction, Store store, CompactionThroughputController throughputController)
int	countStoreFiles()
void	stopCompactions()
void	waitForCompactionToBlock()

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

addAndGetGlobalMemstoreSize, addRegionToMETA, addRegionToSnapshot, append, append, areWritesEnabled, batchMutate, batchMutate, batchReplay, bulkLoadHFiles, checkAndMutate, checkAndRowMutate, checkFamilies, checkReadOnly, checkReadsEnabled, checkSplit, checkTimestamps, close, close, closeHRegion, closeRegionOperation, closeRegionOperation, compact, compactStores, computeHDFSBlocksDistribution, computeHDFSBlocksDistribution, createHRegion, createHRegion, createHRegion, createHRegion, createHRegion, delete, deregisterChildren, doRegionCompactionPrep, equals, execService, flush, flushcache, get, get, getBlockedRequestsCount, getCheckAndMutateChecksFailed, getCheckAndMutateChecksPassed, getClosestRowBefore, getCompactionState, getCompactPriority, getComparator, getCoprocessorHost, getDataInMemoryWithoutWAL, getEarliestFlushTimeForAllStores, getEffectiveDurability, getFilesystem, getHDFSBlocksDistribution, getLargestHStoreSize, getMaxFlushedSeqId, getMaxStoreSeqId, getMemstoreSize, getMetrics, getMVCC, getNextSequenceId, getNumMutationsWithoutWAL, getOldestHfileTs, getOldestSeqIdOfStore, getOpenSeqNum, getReadpoint, getReadRequestsCount, getRegionDir, getRegionDir, getRegionFileSystem, getRegionInfo, getRegionStats, getRowLock, getRowLock, getRowLockInternal, getScanner, getScanner, getSequenceId, getSmallestReadPoint, getSplitPolicy, getStore, getStoreFileList, getStoreFileOpenAndCloseThreadPool, getStoreOpenAndCloseThreadPool, getStores, getTableDesc, getWAL, getWriteRequestsCount, hashCode, hasReferences, heapSize, increment, increment, initialize, instantiateHStore, instantiateRegionScanner, internalFlushcache, internalFlushCacheAndCommit, internalPrepareFlushCache, isAvailable, isClosed, isClosing, isLoadingCfsOnDemandDefault, isMergeable, isReadOnly, isRecovering, isSplittable, main, merge, mergeAdjacent, mutateRow, mutateRowsWithLocks, mutateRowsWithLocks, onConfigurationChange, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, prepareDelete, prepareDeleteTimestamps, prepareToSplit, processRowsWithLocks, processRowsWithLocks, processRowsWithLocks, put, refreshStoreFiles, registerChildren, registerService, releaseRowLocks, replayRecoveredEditsIfAny, reportCompactionRequestEnd, reportCompactionRequestStart, restoreEdit, rowIsInRange, rowIsInRange, setClosing, setCoprocessorHost, setReadsEnabled, setRecovering, startRegionOperation, startRegionOperation, toString, triggerMajorCompaction, updateCellTimestamps, updateReadRequestsCount, updateWriteRequestsCount, waitForFlushesAndCompactions, warmupHRegion

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

CompactionBlockerRegion

public CompactionBlockerRegion(Path tableDir,
                               WAL log,
                               FileSystem fs,
                               Configuration confParam,
                               HRegionInfo info,
                               HTableDescriptor htd,
                               RegionServerServices rsServices)

Method Detail

stopCompactions

public void stopCompactions()

allowCompactions

public void allowCompactions()

waitForCompactionToBlock

public void waitForCompactionToBlock()
                              throws IOException

Throws:

IOException

compact

public boolean compact(CompactionContext compaction,
                       Store store,
                       CompactionThroughputController throughputController)
                throws IOException

Overrides:

compact in class HRegion

Throws:

IOException

countStoreFiles

public int countStoreFiles()