Package org.apache.hadoop.hbase.regionserver

Class TestScannerHeartbeatMessages.HeartbeatHRegion

java.lang.Object

org.apache.hadoop.hbase.regionserver.HRegion

org.apache.hadoop.hbase.regionserver.TestScannerHeartbeatMessages.HeartbeatHRegion

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:

TestScannerHeartbeatMessages

private static class TestScannerHeartbeatMessages.HeartbeatHRegion
extends org.apache.hadoop.hbase.regionserver.HRegion

Custom HRegion class that instantiates RegionScanners with configurable sleep times between fetches of row Results and/or column family cells. Useful for emulating an instance where the server is taking a long time to process a client's scan request

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 int	columnFamilySleepTime
private static int	rowSleepTime
private static boolean	sleepBeforeColumnFamily
private static boolean	sleepBetweenColumnFamilies
private static boolean	sleepBetweenRows

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
HeartbeatHRegion(org.apache.hadoop.fs.Path tableDir, org.apache.hadoop.hbase.wal.WAL wal, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration confParam, org.apache.hadoop.hbase.client.RegionInfo regionInfo, org.apache.hadoop.hbase.client.TableDescriptor htd, org.apache.hadoop.hbase.regionserver.RegionServerServices rsServices)
HeartbeatHRegion(org.apache.hadoop.hbase.regionserver.HRegionFileSystem fs, org.apache.hadoop.hbase.wal.WAL wal, org.apache.hadoop.conf.Configuration confParam, org.apache.hadoop.hbase.client.TableDescriptor htd, org.apache.hadoop.hbase.regionserver.RegionServerServices rsServices)

Method Summary

Modifier and Type	Method	Description
private static void	columnFamilySleep()
protected org.apache.hadoop.hbase.regionserver.RegionScannerImpl	instantiateRegionScanner(org.apache.hadoop.hbase.client.Scan scan, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners, long nonceGroup, long nonce)
private static void	rowSleep()

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, checkInterrupt, 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, 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, throwOnInterrupt, 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

rowSleepTime

private static volatile int rowSleepTime

sleepBetweenRows

private static volatile boolean sleepBetweenRows

sleepBeforeColumnFamily

private static volatile boolean sleepBeforeColumnFamily

columnFamilySleepTime

private static volatile int columnFamilySleepTime

sleepBetweenColumnFamilies

private static volatile boolean sleepBetweenColumnFamilies

Constructor Details

HeartbeatHRegion

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

HeartbeatHRegion

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

Method Details

columnFamilySleep

private static void columnFamilySleep()

rowSleep

private static void rowSleep()

instantiateRegionScanner

protected org.apache.hadoop.hbase.regionserver.RegionScannerImpl instantiateRegionScanner(org.apache.hadoop.hbase.client.Scan scan,
 List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners,
 long nonceGroup,
 long nonce)
                                                                                   throws IOException

Overrides:

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

Throws:

IOException