Class TestRegionReplicationForFlushMarker.HRegionForTest
java.lang.Object
org.apache.hadoop.hbase.regionserver.HRegion
org.apache.hadoop.hbase.regionserver.regionreplication.TestRegionReplicationForFlushMarker.HRegionForTest
- 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:
- TestRegionReplicationForFlushMarker
public static final class TestRegionReplicationForFlushMarker.HRegionForTest
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.PrepareFlushResult, 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
Modifier and TypeFieldDescription(package private) final CyclicBarrier
(package private) final AtomicInteger
(package private) static final String
Fields inherited from class org.apache.hadoop.hbase.regionserver.HRegion
CLOSE_WAIT_ABORT, CLOSE_WAIT_INTERVAL, CLOSE_WAIT_TIME, COMPACTION_AFTER_BULKLOAD_ENABLE, conf, DEEP_OVERHEAD, 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_USE_META_CELL_COMPARATOR, DEFAULT_WAL_HSYNC, FAIR_REENTRANT_CLOSE_LOCK, 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, RECOVERED_EDITS_IGNORE_EOF, REGION_STORAGE_POLICY_KEY, regionReplicationSink, rsServices, SPECIAL_RECOVERED_EDITS_DIR, SPLIT_IGNORE_BLOCKING_ENABLED_KEY, stores, SYSTEM_CACHE_FLUSH_INTERVAL, USE_META_CELL_COMPARATOR, WAL_HSYNC_CONF_KEY
-
Constructor Summary
ConstructorDescriptionHRegionForTest
(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) HRegionForTest
(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 TypeMethodDescriptionprotected org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult
internalPrepareFlushCache
(org.apache.hadoop.hbase.wal.WAL wal, long myseqid, Collection<org.apache.hadoop.hbase.regionserver.HStore> storesToFlush, org.apache.hadoop.hbase.monitoring.MonitoredTask status, boolean writeFlushWalMarker, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker) void
setRegionReplicationSink
(org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink regionReplicationSink) protected void
writeRegionOpenMarker
(org.apache.hadoop.hbase.wal.WAL wal, long openSeqId) Methods inherited from class org.apache.hadoop.hbase.regionserver.HRegion
addReadRequestsCount, addRegionToSnapshot, addWriteRequestsCount, append, append, areWritesEnabled, batchMutate, batchMutate, blockUpdates, bulkLoadHFiles, bulkLoadHFiles, checkAndMutate, checkAndMutate, checkAndMutate, checkAndMutate, checkAndRowMutate, checkAndRowMutate, checkSplit, checkSplit, checkTimestamps, close, close, close, close, closeRegionOperation, closeRegionOperation, compact, compact, compact, compactStores, computeHDFSBlocksDistribution, computeHDFSBlocksDistribution, createHRegion, createHRegion, createHRegion, createHRegion, createRegionDir, decrementCompactionsQueuedCount, decrementFlushesQueuedCount, delete, deregisterChildren, doRegionCompactionPrep, equals, execService, flush, flushcache, flushcache, get, get, getBlockCache, getBlockedRequestsCount, getCellComparator, getCheckAndMutateChecksFailed, getCheckAndMutateChecksPassed, getCompactionState, getCompactPriority, getCoprocessorHost, getCpRequestsCount, getDataInMemoryWithoutWAL, getEarliestFlushTimeForAllStores, getFilesystem, getFilteredReadRequestsCount, getHDFSBlocksDistribution, getLoadStatistics, getLockedRows, getMaxFlushedSeqId, getMaxStoreSeqId, getMemStoreDataSize, getMemStoreFlushSize, getMemStoreHeapSize, getMemStoreOffHeapSize, getMetrics, getMetricsTableRequests, getMinBlockSizeBytes, getMobFileCache, getMVCC, getNextSequenceId, getNumMutationsWithoutWAL, getOldestHfileTs, getOldestSeqIdOfStore, getOpenSeqNum, getReadLockCount, getReadOnlyConfiguration, getReadPoint, getReadRequestsCount, getRegionDir, getRegionFileSystem, getRegionInfo, getRegionReplicationSink, getRegionServicesForStores, getReplicationScope, getRowLock, getRowLock, getRowLockInternal, getScanner, getScanner, getSmallestReadPoint, getStore, getStoreFileList, getStores, getTableDescriptor, getWAL, getWALRegionDir, getWriteRequestsCount, hashCode, hasReferences, heapSize, increment, increment, incrementCompactionsQueuedCount, incrementFlushesQueuedCount, initialize, instantiateHStore, instantiateRegionScanner, internalFlushcache, isAvailable, isClosed, isClosing, isLoadingCfsOnDemandDefault, isMergeable, isReadOnly, isSplittable, mutateRow, mutateRow, mutateRowsWithLocks, newHRegion, onConfigurationChange, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegion, openHRegionFromTableDir, openReadOnlyFileSystemHRegion, put, refreshStoreFiles, refreshStoreFiles, registerChildren, registerService, reportCompactionRequestEnd, reportCompactionRequestFailure, reportCompactionRequestStart, requestCompaction, requestCompaction, requestFlush, restoreEdit, rowIsInRange, rowIsInRange, setBlockCache, setClosing, setCoprocessorHost, setMobFileCache, setReadsEnabled, setRestoredRegion, setTableDescriptor, 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, checkAndMutate, checkAndRowMutate, checkAndRowMutate
-
Field Details
-
USER_THREAD_NAME
- See Also:
-
cyclicBarrier
-
prepareFlushCounter
-
-
Constructor Details
-
HRegionForTest
public HRegionForTest(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) -
HRegionForTest
public HRegionForTest(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)
-
-
Method Details
-
setRegionReplicationSink
public void setRegionReplicationSink(org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink regionReplicationSink) -
writeRegionOpenMarker
protected void writeRegionOpenMarker(org.apache.hadoop.hbase.wal.WAL wal, long openSeqId) throws IOException - Overrides:
writeRegionOpenMarker
in classorg.apache.hadoop.hbase.regionserver.HRegion
- Throws:
IOException
-
internalPrepareFlushCache
protected org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult internalPrepareFlushCache(org.apache.hadoop.hbase.wal.WAL wal, long myseqid, Collection<org.apache.hadoop.hbase.regionserver.HStore> storesToFlush, org.apache.hadoop.hbase.monitoring.MonitoredTask status, boolean writeFlushWalMarker, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker) throws IOException - Overrides:
internalPrepareFlushCache
in classorg.apache.hadoop.hbase.regionserver.HRegion
- Throws:
IOException
-