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:

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

Direct Known Subclasses:

TestIOFencing.BlockCompactionsInCompletionRegion, TestIOFencing.BlockCompactionsInPrepRegion

Enclosing class:

TestIOFencing

public abstract static class TestIOFencing.CompactionBlockerRegion
extends org.apache.hadoop.hbase.regionserver.HRegion

Nested Class Summary

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

org.apache.hadoop.hbase.regionserver.HRegion.BulkLoadListener, org.apache.hadoop.hbase.regionserver.HRegion.FlushResult, org.apache.hadoop.hbase.regionserver.HRegion.FlushResultImpl, org.apache.hadoop.hbase.regionserver.HRegion.RowLockImpl

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

org.apache.hadoop.hbase.regionserver.Region.Operation, org.apache.hadoop.hbase.regionserver.Region.RowLock

Field Summary

Fields

Modifier and Type	Field and Description
(package private) AtomicInteger	compactCount
(package private) CountDownLatch	compactionsBlocked
(package private) CountDownLatch	compactionsWaiting

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

conf, DEEP_OVERHEAD, DEFAULT_CACHE_FLUSH_INTERVAL, DEFAULT_FLUSH_PER_CHANGES, DEFAULT_HBASE_REGIONSERVER_MINIBATCH_SIZE, DEFAULT_MAX_CELL_SIZE, FIXED_OVERHEAD, HBASE_MAX_CELL_SIZE_KEY, HBASE_REGIONSERVER_MINIBATCH_SIZE, lastReplayedCompactionSeqId, lastReplayedOpenRegionSeqId, LOAD_CFS_ON_DEMAND_CONFIG_KEY, MAX_FLUSH_PER_CHANGES, MEMSTORE_FLUSH_PER_CHANGES, MEMSTORE_PERIODIC_FLUSH_INTERVAL, stores, SYSTEM_CACHE_FLUSH_INTERVAL

Constructor Summary

Constructors

Constructor and Description
CompactionBlockerRegion(org.apache.hadoop.fs.Path tableDir, org.apache.hadoop.hbase.wal.WAL log, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration confParam, org.apache.hadoop.hbase.client.RegionInfo info, org.apache.hadoop.hbase.client.TableDescriptor htd, org.apache.hadoop.hbase.regionserver.RegionServerServices rsServices)

Method Summary

Modifier and Type	Method and Description
void	allowCompactions()
boolean	compact(org.apache.hadoop.hbase.regionserver.compactions.CompactionContext compaction, org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController)
boolean	compact(org.apache.hadoop.hbase.regionserver.compactions.CompactionContext compaction, org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.security.User user)
int	countStoreFiles()
void	stopCompactions()
void	waitForCompactionToBlock()

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

addRegionToSnapshot, append, append, areWritesEnabled, batchMutate, batchMutate, batchMutate, batchReplay, blockUpdates, bulkLoadHFiles, bulkLoadHFiles, checkAndMutate, checkAndRowMutate, checkFamilies, checkReadOnly, checkReadsEnabled, checkSplit, checkTimestamps, close, close, closeRegionOperation, closeRegionOperation, compact, compactStores, computeHDFSBlocksDistribution, computeHDFSBlocksDistribution, createHRegion, createHRegion, createRegionDir, decrementCompactionsQueuedCount, delete, deregisterChildren, doRegionCompactionPrep, dropMemStoreContents, equals, execService, flush, flushcache, get, get, get, getBlockedRequestsCount, getCellComparator, getCheckAndMutateChecksFailed, getCheckAndMutateChecksPassed, getCompactionState, getCompactPriority, getCoprocessorHost, getDataInMemoryWithoutWAL, getEarliestFlushTimeForAllStores, getEffectiveDurability, getFilesystem, getFilteredReadRequestsCount, getHDFSBlocksDistribution, getLoadStatistics, getLockedRows, getMaxFlushedSeqId, getMaxStoreSeqId, getMemStoreDataSize, getMemStoreFlushSize, getMemStoreHeapSize, getMemStoreOffHeapSize, getMetrics, getMVCC, getNextSequenceId, getNumMutationsWithoutWAL, getOldestHfileTs, getOldestSeqIdOfStore, getOpenSeqNum, getReadLockCount, getReadPoint, getReadPoint, getReadRequestsCount, getRegionDir, getRegionFileSystem, getRegionInfo, getRegionServicesForStores, getReplicationScope, getRowLock, getRowLock, getRowLockInternal, getScanner, getScanner, getSmallestReadPoint, getSplitPolicy, getStore, getStoreFileList, getStoreFileOpenAndCloseThreadPool, getStoreOpenAndCloseThreadPool, getStores, getTableDescriptor, getWAL, getWALRegionDir, getWriteRequestsCount, hashCode, hasReferences, heapSize, increment, increment, incrementCompactionsQueuedCount, incrementFlushesQueuedCount, initialize, instantiateHStore, instantiateRegionScanner, instantiateRegionScanner, internalFlushcache, internalFlushCacheAndCommit, internalPrepareFlushCache, isAvailable, isClosed, isClosing, isLoadingCfsOnDemandDefault, isMergeable, isReadOnly, isSplittable, mutateRow, mutateRowsWithLocks, onConfigurationChange, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openReadOnlyFileSystemHRegion, prepareDelete, prepareDeleteTimestamps, processRowsWithLocks, processRowsWithLocks, processRowsWithLocks, put, refreshStoreFiles, refreshStoreFiles, registerChildren, registerService, replayRecoveredEditsIfAny, reportCompactionRequestEnd, reportCompactionRequestFailure, reportCompactionRequestStart, requestCompaction, requestCompaction, requestFlush, restoreEdit, rowIsInRange, rowIsInRange, setClosing, setCoprocessorHost, setReadsEnabled, setTimeoutForWriteLock, startRegionOperation, startRegionOperation, toString, unblockUpdates, waitForFlushes, waitForFlushes, waitForFlushesAndCompactions, warmupHRegion

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.regionserver.Region

checkAndMutate, checkAndRowMutate

Field Detail

compactCount

AtomicInteger compactCount

compactionsBlocked

volatile CountDownLatch compactionsBlocked

compactionsWaiting

volatile CountDownLatch compactionsWaiting

Constructor Detail

CompactionBlockerRegion

public CompactionBlockerRegion(org.apache.hadoop.fs.Path tableDir,
                               org.apache.hadoop.hbase.wal.WAL log,
                               org.apache.hadoop.fs.FileSystem fs,
                               org.apache.hadoop.conf.Configuration confParam,
                               org.apache.hadoop.hbase.client.RegionInfo info,
                               org.apache.hadoop.hbase.client.TableDescriptor htd,
                               org.apache.hadoop.hbase.regionserver.RegionServerServices rsServices)

Method Detail

stopCompactions

public void stopCompactions()

allowCompactions

public void allowCompactions()

waitForCompactionToBlock

public void waitForCompactionToBlock()
                              throws IOException

Throws:

IOException

compact

public boolean compact(org.apache.hadoop.hbase.regionserver.compactions.CompactionContext compaction,
                       org.apache.hadoop.hbase.regionserver.HStore store,
                       org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController)
                throws IOException

Overrides:

compact in class org.apache.hadoop.hbase.regionserver.HRegion

Throws:

IOException

compact

public boolean compact(org.apache.hadoop.hbase.regionserver.compactions.CompactionContext compaction,
                       org.apache.hadoop.hbase.regionserver.HStore store,
                       org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController,
                       org.apache.hadoop.hbase.security.User user)
                throws IOException

Overrides:

compact in class org.apache.hadoop.hbase.regionserver.HRegion

Throws:

IOException

countStoreFiles

public int countStoreFiles()