Package 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
    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_REGION_STORAGE_POLICY, 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, RECOVERED_EDITS_IGNORE_EOF, REGION_STORAGE_POLICY_KEY, regionLockHolders, regionServicesForStores, rowProcessorExecutor, rowProcessorTimeout, rsServices, scannerReadPoints, smallestReadPointCalcLock, 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
    Description
    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(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 Summary

    Modifier and Type
    Method
    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, 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, getMetricsTableRequests, getMinBlockSizeBytes, 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 Details

  • Constructor Details

    • 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 Details