org.apache.hadoop.hbase.regionserver

Class TestRegionInterrupt.InterruptInterceptingHRegion

java.lang.Object

org.apache.hadoop.hbase.regionserver.HRegion

org.apache.hadoop.hbase.regionserver.TestRegionInterrupt.InterruptInterceptingHRegion

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

Enclosing class:

TestRegionInterrupt

public static class TestRegionInterrupt.InterruptInterceptingHRegion
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.ObservedExceptionsInBatch, org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult, org.apache.hadoop.hbase.regionserver.HRegion.RowLockContext, org.apache.hadoop.hbase.regionserver.HRegion.RowLockImpl, org.apache.hadoop.hbase.regionserver.HRegion.WriteState

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
private static boolean	interrupted

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

busyWaitDuration, checkAndMutateChecksFailed, checkAndMutateChecksPassed, CLOSE_WAIT_ABORT, CLOSE_WAIT_INTERVAL, CLOSE_WAIT_TIME, closed, closing, COMPACTION_AFTER_BULKLOAD_ENABLE, compactionNumBytesCompacted, compactionNumFilesCompacted, compactionsFailed, compactionsFinished, compactionsQueued, conf, dataInMemoryWithoutWAL, DEEP_OVERHEAD, DEFAULT_BUSY_WAIT_DURATION, DEFAULT_CACHE_FLUSH_INTERVAL, DEFAULT_CLOSE_WAIT_ABORT, DEFAULT_CLOSE_WAIT_INTERVAL, DEFAULT_CLOSE_WAIT_TIME, DEFAULT_FAIR_REENTRANT_CLOSE_LOCK, DEFAULT_FLUSH_PER_CHANGES, DEFAULT_HBASE_REGIONSERVER_MINIBATCH_SIZE, DEFAULT_MAX_CELL_SIZE, DEFAULT_ROW_PROCESSOR_TIMEOUT, DEFAULT_ROWLOCK_WAIT_DURATION, DEFAULT_USE_META_CELL_COMPARATOR, DEFAULT_WAL_HSYNC, FAIR_REENTRANT_CLOSE_LOCK, filteredReadRequestsCount, FIXED_OVERHEAD, flushesQueued, HBASE_MAX_CELL_SIZE_KEY, HBASE_REGIONSERVER_MINIBATCH_SIZE, lastReplayedCompactionSeqId, lastReplayedOpenRegionSeqId, LOAD_CFS_ON_DEMAND_CONFIG_KEY, lock, MAX_FLUSH_PER_CHANGES, maxBusyWaitDuration, maxBusyWaitMultiplier, maxCellSize, maxSeqIdInStores, MEMSTORE_FLUSH_PER_CHANGES, MEMSTORE_PERIODIC_FLUSH_INTERVAL, memstoreFlushSize, numMutationsWithoutWAL, readRequestsCount, regionLockHolders, regionServicesForStores, rowProcessorExecutor, rowProcessorTimeout, rsServices, scannerReadPoints, SPECIAL_RECOVERED_EDITS_DIR, SPLIT_IGNORE_BLOCKING_ENABLED_KEY, stores, SYSTEM_CACHE_FLUSH_INTERVAL, timestampSlop, USE_META_CELL_COMPARATOR, WAL_HSYNC_CONF_KEY, writeRequestsCount, writestate

Constructor Summary

Constructors

Constructor and Description
InterruptInterceptingHRegion(org.apache.hadoop.hbase.regionserver.HRegionFileSystem fs, org.apache.hadoop.hbase.wal.WAL wal, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.TableDescriptor htd, org.apache.hadoop.hbase.regionserver.RegionServerServices rsServices)
InterruptInterceptingHRegion(org.apache.hadoop.fs.Path tableDir, org.apache.hadoop.hbase.wal.WAL wal, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.RegionInfo regionInfo, org.apache.hadoop.hbase.client.TableDescriptor htd, org.apache.hadoop.hbase.regionserver.RegionServerServices rsServices)

Method Summary

Modifier and Type	Method and Description
(package private) void	checkInterrupt()
(package private) IOException	throwOnInterrupt(Throwable t)
static boolean	wasInterrupted()

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

addReadRequestsCount, addRegionToSnapshot, addWriteRequestsCount, append, append, areWritesEnabled, batchMutate, batchMutate, batchMutate, batchReplay, blockUpdates, bulkLoadHFiles, bulkLoadHFiles, checkAndMutate, checkAndMutate, checkAndMutate, checkAndMutate, checkAndRowMutate, checkAndRowMutate, checkFamilies, checkFamily, checkRow, checkSplit, checkSplit, checkTimestamps, close, close, closeRegionOperation, closeRegionOperation, compact, compact, compact, compactStore, compactStores, computeHDFSBlocksDistribution, computeHDFSBlocksDistribution, createHRegion, createHRegion, createHRegion, createHRegion, createRegionDir, createRegionSpan, decrementCompactionsQueuedCount, decrementFlushesQueuedCount, decrMemStoreSize, delete, deregisterChildren, disableInterrupts, doRegionCompactionPrep, enableInterrupts, equals, execService, flush, flushcache, flushcache, get, get, getBaseConf, getBlockCache, getBlockedRequestsCount, getCellComparator, getCheckAndMutateChecksFailed, getCheckAndMutateChecksPassed, getCompactionState, getCompactPriority, getCoprocessorHost, getDataInMemoryWithoutWAL, getEarliestFlushTimeForAllStores, getFilesystem, getFilteredReadRequestsCount, getHDFSBlocksDistribution, getLoadStatistics, getLockedRows, getMaxFlushedSeqId, getMaxStoreSeqId, getMemStoreDataSize, getMemStoreFlushSize, getMemStoreHeapSize, getMemStoreOffHeapSize, getMetrics, getMobFileCache, getMVCC, getNextSequenceId, getNumMutationsWithoutWAL, getOldestHfileTs, getOldestSeqIdOfStore, getOpenSeqNum, getPrepareFlushResult, getReadLockCount, getReadOnlyConfiguration, getReadPoint, getReadRequestsCount, getRegionDir, getRegionFileSystem, getRegionInfo, getRegionServerServices, getRegionServicesForStores, getRegionWALFileSystem, getReplicationScope, getRowLock, getRowLock, getRowLockInternal, getScanner, getScanner, getSmallestReadPoint, getSplitPolicy, getStore, getStoreFileList, getStoreFileOpenAndCloseThreadPool, getStores, getTableDescriptor, getWAL, getWalFileSystem, getWALRegionDir, getWriteRequestsCount, hashCode, hasReferences, heapSize, incMemStoreSize, increment, increment, incrementCompactionsQueuedCount, incrementFlushesQueuedCount, initialize, initialize, instantiateHStore, instantiateRegionScanner, internalFlushcache, internalFlushCacheAndCommit, internalPrepareFlushCache, isAvailable, isClosed, isClosing, isLoadingCfsOnDemandDefault, isMergeable, isReadOnly, isReadsEnabled, isSplittable, metricsUpdateForGet, mutateRow, mutateRow, mutateRowsWithLocks, newHRegion, onConfigurationChange, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegionFromTableDir, openReadOnlyFileSystemHRegion, prepareGet, processRowsWithLocks, processRowsWithLocks, processRowsWithLocks, put, refreshStoreFiles, refreshStoreFiles, registerChildren, registerService, replayRecoveredEditsIfAny, replayWALBulkLoadEventMarker, replayWALCompactionMarker, replayWALFlushCommitMarker, replayWALFlushMarker, replayWALFlushStartMarker, replayWALRegionEventMarker, reportCompactionRequestEnd, reportCompactionRequestFailure, reportCompactionRequestStart, requestCompaction, requestCompaction, requestFlush, restoreEdit, rowIsInRange, rowIsInRange, setBlockCache, setClosing, setCompleteSequenceId, setCoprocessorHost, setMobFileCache, setReadsEnabled, setRestoredRegion, setTableDescriptor, setTimeoutForWriteLock, shouldFlush, shouldFlushStore, startRegionOperation, startRegionOperation, throwException, toString, unblockUpdates, waitForFlushes, waitForFlushes, waitForFlushesAndCompactions, warmupHRegion, writeRegionOpenMarker

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, checkAndMutate, checkAndRowMutate, checkAndRowMutate

Field Detail

interrupted

private static boolean interrupted

Constructor Detail

InterruptInterceptingHRegion

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

InterruptInterceptingHRegion

public InterruptInterceptingHRegion(org.apache.hadoop.hbase.regionserver.HRegionFileSystem fs,
                                    org.apache.hadoop.hbase.wal.WAL wal,
                                    org.apache.hadoop.conf.Configuration conf,
                                    org.apache.hadoop.hbase.client.TableDescriptor htd,
                                    org.apache.hadoop.hbase.regionserver.RegionServerServices rsServices)

Method Detail

wasInterrupted

public static boolean wasInterrupted()

checkInterrupt

void checkInterrupt()
             throws org.apache.hadoop.hbase.NotServingRegionException,
                    InterruptedIOException

Overrides:

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

Throws:

org.apache.hadoop.hbase.NotServingRegionException

InterruptedIOException

throwOnInterrupt

IOException throwOnInterrupt(Throwable t)

Overrides:

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