@InterfaceAudience.Private public class HRegion extends Object implements HeapSize, PropagatingConfigurationObserver, Region
Modifier and Type | Class and Description |
---|---|
static class |
HRegion.FlushResultImpl
Objects from this class are created when flushing to describe all the different states that
that method ends up in.
|
static class |
HRegion.RowLockImpl |
Region.BulkLoadListener, Region.FlushResult, Region.Operation, Region.RowLock
Modifier and Type | Field and Description |
---|---|
protected Configuration |
conf |
static long |
DEEP_OVERHEAD |
static int |
DEFAULT_CACHE_FLUSH_INTERVAL
Default interval for the memstore flush
|
static long |
DEFAULT_FLUSH_PER_CHANGES |
static long |
FIXED_OVERHEAD |
protected long |
lastReplayedCompactionSeqId |
protected long |
lastReplayedOpenRegionSeqId
The sequence id of the last replayed open region event from the primary region.
|
static String |
LOAD_CFS_ON_DEMAND_CONFIG_KEY |
static Log |
LOG |
static long |
MAX_FLUSH_PER_CHANGES
The following MAX_FLUSH_PER_CHANGES is large enough because each KeyValue has 20+ bytes
overhead.
|
static String |
MEMSTORE_FLUSH_PER_CHANGES
Conf key to force a flush if there are already enough changes for one region in memstore
|
static String |
MEMSTORE_PERIODIC_FLUSH_INTERVAL
Conf key for the periodic flush interval
|
AtomicLong |
memstoreSize |
static int |
META_CACHE_FLUSH_INTERVAL |
protected Map<byte[],Store> |
stores |
Constructor and Description |
---|
HRegion(HRegionFileSystem fs,
WAL wal,
Configuration confParam,
HTableDescriptor htd,
RegionServerServices rsServices)
HRegion constructor.
|
HRegion(Path tableDir,
WAL wal,
FileSystem fs,
Configuration confParam,
HRegionInfo regionInfo,
HTableDescriptor htd,
RegionServerServices rsServices)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
long |
addAndGetGlobalMemstoreSize(long memStoreSize)
Increase the size of mem store in this region and the size of global mem
store
|
static void |
addRegionToMETA(HRegion meta,
HRegion r)
Inserts a new region's meta information into the passed
meta region. |
void |
addRegionToSnapshot(HBaseProtos.SnapshotDescription desc,
ForeignExceptionSnare exnSnare)
Complete taking the snapshot on the region.
|
Result |
append(Append append) |
Result |
append(Append append,
long nonceGroup,
long nonce)
Perform one or more append operations on a row.
|
boolean |
areWritesEnabled() |
OperationStatus[] |
batchMutate(Mutation[] mutations) |
OperationStatus[] |
batchMutate(Mutation[] mutations,
long nonceGroup,
long nonce)
Perform a batch of mutations.
|
OperationStatus[] |
batchReplay(WALSplitter.MutationReplay[] mutations,
long replaySeqId)
Replay a batch of mutations.
|
boolean |
bulkLoadHFiles(Collection<Pair<byte[],String>> familyPaths,
boolean assignSeqId,
Region.BulkLoadListener bulkLoadListener)
Attempts to atomically load a group of hfiles.
|
boolean |
checkAndMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Mutation w,
boolean writeToWAL)
Atomically checks if a row/family/qualifier value matches the expected val
If it does, it performs the row mutations.
|
boolean |
checkAndRowMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
RowMutations rm,
boolean writeToWAL)
Atomically checks if a row/family/qualifier value matches the expected val
If it does, it performs the row mutations.
|
void |
checkFamilies(Collection<byte[]> families)
Check the collection of families for validity.
|
protected void |
checkReadOnly() |
protected void |
checkReadsEnabled() |
byte[] |
checkSplit()
Return the splitpoint.
|
void |
checkTimestamps(Map<byte[],List<Cell>> familyMap,
long now)
Check the collection of families for valid timestamps
|
Map<byte[],List<StoreFile>> |
close()
Close down this HRegion.
|
Map<byte[],List<StoreFile>> |
close(boolean abort)
Close down this HRegion.
|
static void |
closeHRegion(HRegion r)
This will do the necessary cleanup a call to
createHRegion(HRegionInfo, Path, Configuration, HTableDescriptor)
requires. |
void |
closeRegionOperation()
Closes the region operation lock.
|
void |
closeRegionOperation(Region.Operation operation)
Closes the lock.
|
void |
compact(boolean majorCompaction)
Synchronously compact all stores in the region.
|
boolean |
compact(CompactionContext compaction,
Store store,
CompactionThroughputController throughputController) |
void |
compactStores()
This is a helper function that compact all the stores synchronously
It is used by utilities and testing
|
static HDFSBlocksDistribution |
computeHDFSBlocksDistribution(Configuration conf,
HTableDescriptor tableDescriptor,
HRegionInfo regionInfo)
This is a helper function to compute HDFS block distribution on demand
|
static HDFSBlocksDistribution |
computeHDFSBlocksDistribution(Configuration conf,
HTableDescriptor tableDescriptor,
HRegionInfo regionInfo,
Path tablePath)
This is a helper function to compute HDFS block distribution on demand
|
static HRegion |
createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor)
Convenience method creating new HRegions.
|
static HRegion |
createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal) |
static HRegion |
createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal,
boolean initialize)
Convenience method creating new HRegions.
|
static HRegion |
createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal,
boolean initialize,
boolean ignoreWAL)
Convenience method creating new HRegions.
|
static HRegion |
createHRegion(HRegionInfo info,
Path rootDir,
Path tableDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal,
boolean initialize,
boolean ignoreWAL)
Convenience method creating new HRegions.
|
void |
delete(Delete delete)
Deletes the specified cells/row.
|
void |
deregisterChildren(ConfigurationManager manager)
Needs to be called to deregister the children from the manager.
|
protected void |
doRegionCompactionPrep() |
boolean |
equals(Object o) |
Message |
execService(RpcController controller,
ClientProtos.CoprocessorServiceCall call)
Executes a single protocol buffer coprocessor endpoint
Service method using
the registered protocol handlers. |
Region.FlushResult |
flush(boolean force)
Flush the cache.
|
Region.FlushResult |
flushcache(boolean forceFlushAllStores,
boolean writeFlushRequestWalMarker)
Flush the cache.
|
Result |
get(Get get)
Do a get based on the get parameter.
|
List<Cell> |
get(Get get,
boolean withCoprocessor)
Do a get based on the get parameter.
|
long |
getBlockedRequestsCount() |
long |
getCheckAndMutateChecksFailed() |
long |
getCheckAndMutateChecksPassed() |
Result |
getClosestRowBefore(byte[] row,
byte[] family)
Return all the data for the row that matches row exactly,
or the one that immediately preceeds it, at or immediately before
ts.
|
AdminProtos.GetRegionInfoResponse.CompactionState |
getCompactionState() |
int |
getCompactPriority() |
KeyValue.KVComparator |
getComparator() |
RegionCoprocessorHost |
getCoprocessorHost() |
long |
getDataInMemoryWithoutWAL() |
long |
getEarliestFlushTimeForAllStores() |
protected Durability |
getEffectiveDurability(Durability d)
Returns effective durability from the passed durability and
the table descriptor.
|
FileSystem |
getFilesystem() |
HDFSBlocksDistribution |
getHDFSBlocksDistribution() |
long |
getLargestHStoreSize() |
long |
getMaxFlushedSeqId() |
Map<byte[],Long> |
getMaxStoreSeqId() |
long |
getMemstoreSize() |
MetricsRegion |
getMetrics() |
MultiVersionConsistencyControl |
getMVCC() |
protected long |
getNextSequenceId(WAL wal)
Method to safely get the next sequence number.
|
long |
getNumMutationsWithoutWAL() |
long |
getOldestHfileTs(boolean majorCompactioOnly)
This can be used to determine the last time all files of this region were major compacted.
|
long |
getOldestSeqIdOfStore(byte[] familyName) |
long |
getOpenSeqNum() |
long |
getReadpoint(IsolationLevel isolationLevel) |
long |
getReadRequestsCount() |
static Path |
getRegionDir(Path rootdir,
HRegionInfo info)
Deprecated.
|
static Path |
getRegionDir(Path tabledir,
String name)
Deprecated.
|
HRegionFileSystem |
getRegionFileSystem() |
HRegionInfo |
getRegionInfo() |
ClientProtos.RegionLoadStats |
getRegionStats() |
Region.RowLock |
getRowLock(byte[] row)
Acquires a lock on the given row.
|
Region.RowLock |
getRowLock(byte[] row,
boolean waitForLock)
Tries to acquire a lock on the given row.
|
protected Region.RowLock |
getRowLockInternal(byte[] row,
boolean waitForLock)
A version of getRowLock(byte[], boolean) to use when a region operation has already been
started (the calling thread has already acquired the region-close-guard lock).
|
RegionScanner |
getScanner(Scan scan)
Return an iterator that scans over the HRegion, returning the indicated
columns and rows specified by the
Scan . |
protected RegionScanner |
getScanner(Scan scan,
List<KeyValueScanner> additionalScanners) |
AtomicLong |
getSequenceId()
Do not change this sequence id.
|
long |
getSmallestReadPoint() |
RegionSplitPolicy |
getSplitPolicy() |
Store |
getStore(byte[] column)
Return the Store for the given family
|
List<String> |
getStoreFileList(byte[][] columns) |
protected ThreadPoolExecutor |
getStoreFileOpenAndCloseThreadPool(String threadNamePrefix) |
protected ThreadPoolExecutor |
getStoreOpenAndCloseThreadPool(String threadNamePrefix) |
List<Store> |
getStores()
Return the list of Stores managed by this region
|
HTableDescriptor |
getTableDesc() |
WAL |
getWAL() |
long |
getWriteRequestsCount() |
int |
hashCode() |
boolean |
hasReferences() |
long |
heapSize() |
Result |
increment(Increment increment) |
Result |
increment(Increment increment,
long nonceGroup,
long nonce)
Perform one or more increment operations on a row.
|
long |
initialize()
Deprecated.
use HRegion.createHRegion() or HRegion.openHRegion()
|
protected HStore |
instantiateHStore(HColumnDescriptor family) |
protected RegionScanner |
instantiateRegionScanner(Scan scan,
List<KeyValueScanner> additionalScanners) |
protected Region.FlushResult |
internalFlushcache(WAL wal,
long myseqid,
Collection<Store> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker)
Flush the memstore.
|
protected Region.FlushResult |
internalFlushCacheAndCommit(WAL wal,
MonitoredTask status,
org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult prepareResult,
Collection<Store> storesToFlush) |
protected org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult |
internalPrepareFlushCache(WAL wal,
long myseqid,
Collection<Store> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker) |
boolean |
isAvailable() |
boolean |
isClosed() |
boolean |
isClosing() |
boolean |
isLoadingCfsOnDemandDefault() |
boolean |
isMergeable() |
boolean |
isReadOnly() |
boolean |
isRecovering() |
boolean |
isSplittable() |
static void |
main(String[] args)
Facility for dumping and compacting catalog tables.
|
static HRegion |
merge(HRegion a,
HRegion b)
Merge two regions whether they are adjacent or not.
|
static HRegion |
mergeAdjacent(HRegion srcA,
HRegion srcB)
Merge two HRegions.
|
void |
mutateRow(RowMutations rm)
Performs multiple mutations atomically on a single row.
|
void |
mutateRowsWithLocks(Collection<Mutation> mutations,
Collection<byte[]> rowsToLock)
Perform atomic mutations within the region w/o nonces.
|
void |
mutateRowsWithLocks(Collection<Mutation> mutations,
Collection<byte[]> rowsToLock,
long nonceGroup,
long nonce)
Perform atomic mutations within the region.
|
void |
onConfigurationChange(Configuration conf)
This method would be called by the
ConfigurationManager
object when the Configuration object is reloaded from disk. |
protected HRegion |
openHRegion(CancelableProgressable reporter)
Open HRegion.
|
static HRegion |
openHRegion(Configuration conf,
FileSystem fs,
Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal)
Open a Region.
|
static HRegion |
openHRegion(Configuration conf,
FileSystem fs,
Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
openHRegion(Configuration conf,
FileSystem fs,
Path rootDir,
Path tableDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
openHRegion(HRegion other,
CancelableProgressable reporter)
Useful when reopening a closed region (normally for unit tests)
|
static HRegion |
openHRegion(HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf)
Open a Region.
|
static HRegion |
openHRegion(HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
openHRegion(Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf)
Open a Region.
|
static HRegion |
openHRegion(Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static Region |
openHRegion(Region other,
CancelableProgressable reporter) |
void |
prepareDelete(Delete delete)
Prepare a delete for a row mutation processor
|
void |
prepareDeleteTimestamps(Mutation mutation,
Map<byte[],List<Cell>> familyMap,
byte[] byteNow)
Set up correct timestamps in the KVs in Delete object.
|
protected void |
prepareToSplit()
Give the region a chance to prepare before it is split.
|
void |
processRowsWithLocks(RowProcessor<?,?> processor)
Performs atomic multiple reads and writes on a given row.
|
void |
processRowsWithLocks(RowProcessor<?,?> processor,
long nonceGroup,
long nonce)
Performs atomic multiple reads and writes on a given row.
|
void |
processRowsWithLocks(RowProcessor<?,?> processor,
long timeout,
long nonceGroup,
long nonce)
Performs atomic multiple reads and writes on a given row.
|
void |
put(Put put)
Puts some data in the table.
|
boolean |
refreshStoreFiles()
Check the region's underlying store files, open the files that have not
been opened yet, and remove the store file readers for store files no
longer available.
|
void |
registerChildren(ConfigurationManager manager)
Needs to be called to register the children to the manager.
|
boolean |
registerService(Service instance)
Registers a new protocol buffer
Service subclass as a coprocessor endpoint to
be available for handling
Region#execService(com.google.protobuf.RpcController,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.CoprocessorServiceCall) } calls. |
void |
releaseRowLocks(List<Region.RowLock> rowLocks)
If the given list of row locks is not null, releases all locks.
|
protected long |
replayRecoveredEditsIfAny(Path regiondir,
Map<byte[],Long> maxSeqIdInStores,
CancelableProgressable reporter,
MonitoredTask status)
Read the edits put under this region by wal splitting process.
|
void |
reportCompactionRequestEnd(boolean isMajor,
int numFiles,
long filesSizeCompacted) |
void |
reportCompactionRequestStart(boolean isMajor) |
protected boolean |
restoreEdit(Store s,
Cell cell)
Used by tests
|
static boolean |
rowIsInRange(HRegionInfo info,
byte[] row)
Determines if the specified row is within the row range specified by the
specified HRegionInfo
|
static boolean |
rowIsInRange(HRegionInfo info,
byte[] row,
int offset,
short length) |
void |
setClosing(boolean closing)
Exposed for some very specific unit tests.
|
void |
setCoprocessorHost(RegionCoprocessorHost coprocessorHost) |
void |
setReadsEnabled(boolean readsEnabled) |
void |
setRecovering(boolean newState)
Reset recovering state of current region
|
void |
startRegionOperation()
This method needs to be called before any public call that reads or
modifies data.
|
void |
startRegionOperation(Region.Operation op)
This method needs to be called before any public call that reads or
modifies data.
|
String |
toString() |
void |
triggerMajorCompaction()
Trigger major compaction on all stores in the region.
|
void |
updateCellTimestamps(Iterable<List<Cell>> cellItr,
byte[] now)
Replace any cell timestamps set to HConstants#LATEST_TIMESTAMP with the
provided current timestamp.
|
void |
updateReadRequestsCount(long i)
Update the read request count for this region
|
void |
updateWriteRequestsCount(long i)
Update the write request count for this region
|
void |
waitForFlushesAndCompactions()
Wait for all current flushes and compactions of the region to complete
|
static void |
warmupHRegion(HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter) |
public static final Log LOG
public static final String LOAD_CFS_ON_DEMAND_CONFIG_KEY
protected volatile long lastReplayedOpenRegionSeqId
protected volatile long lastReplayedCompactionSeqId
public final AtomicLong memstoreSize
protected final Configuration conf
public static final String MEMSTORE_PERIODIC_FLUSH_INTERVAL
public static final int DEFAULT_CACHE_FLUSH_INTERVAL
public static final int META_CACHE_FLUSH_INTERVAL
public static final String MEMSTORE_FLUSH_PER_CHANGES
public static final long DEFAULT_FLUSH_PER_CHANGES
public static final long MAX_FLUSH_PER_CHANGES
public static final long FIXED_OVERHEAD
public static final long DEEP_OVERHEAD
@Deprecated public HRegion(Path tableDir, WAL wal, FileSystem fs, Configuration confParam, HRegionInfo regionInfo, HTableDescriptor htd, RegionServerServices rsServices)
createHRegion(org.apache.hadoop.hbase.HRegionInfo, Path, Configuration, org.apache.hadoop.hbase.HTableDescriptor)
or openHRegion(org.apache.hadoop.hbase.HRegionInfo, org.apache.hadoop.hbase.HTableDescriptor, org.apache.hadoop.hbase.wal.WAL, Configuration)
method.tableDir
- qualified path of directory where region should be located,
usually the table directory.wal
- The WAL is the outbound log for any updates to the HRegion
The wal file is a logfile from the previous execution that's
custom-computed for this HRegion. The HRegionServer computes and sorts the
appropriate wal info for this HRegion. If there is a previous wal file
(implying that the HRegion has been written-to before), then read it from
the supplied path.fs
- is the filesystem.confParam
- is global configuration settings.regionInfo
- - HRegionInfo that describes the region
is new), then read them from the supplied path.htd
- the table descriptorrsServices
- reference to RegionServerServices
or nullpublic HRegion(HRegionFileSystem fs, WAL wal, Configuration confParam, HTableDescriptor htd, RegionServerServices rsServices)
createHRegion(org.apache.hadoop.hbase.HRegionInfo, Path, Configuration, org.apache.hadoop.hbase.HTableDescriptor)
or openHRegion(org.apache.hadoop.hbase.HRegionInfo, org.apache.hadoop.hbase.HTableDescriptor, org.apache.hadoop.hbase.wal.WAL, Configuration)
method.fs
- is the filesystem.wal
- The WAL is the outbound log for any updates to the HRegion
The wal file is a logfile from the previous execution that's
custom-computed for this HRegion. The HRegionServer computes and sorts the
appropriate wal info for this HRegion. If there is a previous wal file
(implying that the HRegion has been written-to before), then read it from
the supplied path.confParam
- is global configuration settings.htd
- the table descriptorrsServices
- reference to RegionServerServices
or nullpublic long getSmallestReadPoint()
@Deprecated public long initialize() throws IOException
IOException
- epublic boolean hasReferences()
public HDFSBlocksDistribution getHDFSBlocksDistribution()
getHDFSBlocksDistribution
in interface Region
public static HDFSBlocksDistribution computeHDFSBlocksDistribution(Configuration conf, HTableDescriptor tableDescriptor, HRegionInfo regionInfo) throws IOException
conf
- configurationtableDescriptor
- HTableDescriptor of the tableregionInfo
- encoded name of the regionIOException
public static HDFSBlocksDistribution computeHDFSBlocksDistribution(Configuration conf, HTableDescriptor tableDescriptor, HRegionInfo regionInfo, Path tablePath) throws IOException
conf
- configurationtableDescriptor
- HTableDescriptor of the tableregionInfo
- encoded name of the regiontablePath
- the table directoryIOException
public long addAndGetGlobalMemstoreSize(long memStoreSize)
public HRegionInfo getRegionInfo()
getRegionInfo
in interface Region
public long getReadRequestsCount()
getReadRequestsCount
in interface Region
public void updateReadRequestsCount(long i)
Region
updateReadRequestsCount
in interface Region
i
- incrementpublic long getWriteRequestsCount()
getWriteRequestsCount
in interface Region
public void updateWriteRequestsCount(long i)
Region
updateWriteRequestsCount
in interface Region
i
- incrementpublic long getMemstoreSize()
getMemstoreSize
in interface Region
public long getNumMutationsWithoutWAL()
getNumMutationsWithoutWAL
in interface Region
public long getDataInMemoryWithoutWAL()
getDataInMemoryWithoutWAL
in interface Region
public long getBlockedRequestsCount()
getBlockedRequestsCount
in interface Region
public long getCheckAndMutateChecksPassed()
getCheckAndMutateChecksPassed
in interface Region
public long getCheckAndMutateChecksFailed()
getCheckAndMutateChecksFailed
in interface Region
public MetricsRegion getMetrics()
getMetrics
in interface Region
public boolean isClosed()
public boolean isClosing()
public boolean isReadOnly()
isReadOnly
in interface Region
public void setRecovering(boolean newState)
public boolean isRecovering()
isRecovering
in interface Region
public boolean isAvailable()
isAvailable
in interface Region
public boolean isSplittable()
public boolean isMergeable()
public boolean areWritesEnabled()
public MultiVersionConsistencyControl getMVCC()
public long getMaxFlushedSeqId()
getMaxFlushedSeqId
in interface Region
public long getReadpoint(IsolationLevel isolationLevel)
getReadpoint
in interface Region
public boolean isLoadingCfsOnDemandDefault()
isLoadingCfsOnDemandDefault
in interface Region
public Map<byte[],List<StoreFile>> close() throws IOException
This method could take some time to execute, so don't call it from a time-sensitive thread.
IOException
- eDroppedSnapshotException
- Thrown when replay of wal is required
because a Snapshot was not properly persisted. The region is put in closing mode, and the
caller MUST abort after this.public Map<byte[],List<StoreFile>> close(boolean abort) throws IOException
abort
- true if server is aborting (only during testing)IOException
- eDroppedSnapshotException
- Thrown when replay of wal is required
because a Snapshot was not properly persisted. The region is put in closing mode, and the
caller MUST abort after this.public void setClosing(boolean closing)
public void waitForFlushesAndCompactions()
Region
waitForFlushesAndCompactions
in interface Region
protected ThreadPoolExecutor getStoreOpenAndCloseThreadPool(String threadNamePrefix)
protected ThreadPoolExecutor getStoreFileOpenAndCloseThreadPool(String threadNamePrefix)
public HTableDescriptor getTableDesc()
getTableDesc
in interface Region
public WAL getWAL()
public FileSystem getFilesystem()
FileSystem
being used by this regionpublic HRegionFileSystem getRegionFileSystem()
HRegionFileSystem
used by this regionpublic long getEarliestFlushTimeForAllStores()
getEarliestFlushTimeForAllStores
in interface Region
public long getOldestHfileTs(boolean majorCompactioOnly) throws IOException
Region
getOldestHfileTs
in interface Region
majorCompactioOnly
- Only consider HFile that are the result of major compactionIOException
public long getLargestHStoreSize()
public KeyValue.KVComparator getComparator()
protected void doRegionCompactionPrep() throws IOException
IOException
public void triggerMajorCompaction() throws IOException
Region
Compaction will be performed asynchronously to this call by the RegionServer's
CompactSplitThread. See also Store.triggerMajorCompaction()
triggerMajorCompaction
in interface Region
IOException
public void compact(boolean majorCompaction) throws IOException
Region
This operation could block for a long time, so don't call it from a time-sensitive thread.
Note that no locks are taken to prevent possible conflicts between compaction and splitting activities. The regionserver does not normally compact and split in parallel. However by calling this method you may introduce unexpected and unhandled concurrency. Don't do this unless you know what you are doing.
compact
in interface Region
majorCompaction
- True to force a major compaction regardless of thresholdsIOException
public void compactStores() throws IOException
IOException
- epublic boolean compact(CompactionContext compaction, Store store, CompactionThroughputController throughputController) throws IOException
IOException
public Region.FlushResult flush(boolean force) throws IOException
Region
When this method is called the cache will be flushed unless:
This method may block for some time, so it should not be called from a time-sensitive thread.
flush
in interface Region
force
- whether we want to force a flush of all storesIOException
- general io exceptionspublic Region.FlushResult flushcache(boolean forceFlushAllStores, boolean writeFlushRequestWalMarker) throws IOException
This method may block for some time, so it should not be called from a time-sensitive thread.
forceFlushAllStores
- whether we want to flush all storeswriteFlushRequestWalMarker
- whether to write the flush request marker to WALIOException
- general io exceptionsDroppedSnapshotException
- Thrown when replay of wal is required
because a Snapshot was not properly persisted. The region is put in closing mode, and the
caller MUST abort after this.protected Region.FlushResult internalFlushcache(WAL wal, long myseqid, Collection<Store> storesToFlush, MonitoredTask status, boolean writeFlushWalMarker) throws IOException
This method may block for some time. Every time you call it, we up the regions sequence id even if we don't flush; i.e. the returned region id will be at least one larger than the last edit applied to this region. The returned id does not refer to an actual edit. The returned id can be used for say installing a bulk loaded file just ahead of the last hfile that was the result of this flush, etc.
wal
- Null if we're NOT to go via wal.myseqid
- The seqid to use if wal
is null writing out flush
file.storesToFlush
- The list of stores to flush.IOException
- general io exceptionsDroppedSnapshotException
- Thrown when replay of wal is required because a Snapshot was not
properly persisted.protected org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult internalPrepareFlushCache(WAL wal, long myseqid, Collection<Store> storesToFlush, MonitoredTask status, boolean writeFlushWalMarker) throws IOException
IOException
protected Region.FlushResult internalFlushCacheAndCommit(WAL wal, MonitoredTask status, org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult prepareResult, Collection<Store> storesToFlush) throws IOException
IOException
protected long getNextSequenceId(WAL wal) throws IOException
IOException
public Result getClosestRowBefore(byte[] row, byte[] family) throws IOException
Region
getClosestRowBefore
in interface Region
IOException
public RegionScanner getScanner(Scan scan) throws IOException
Region
Scan
.
This Iterator must be closed by the caller.
getScanner
in interface Region
scan
- configured Scan
IOException
- read exceptionsprotected RegionScanner getScanner(Scan scan, List<KeyValueScanner> additionalScanners) throws IOException
IOException
protected RegionScanner instantiateRegionScanner(Scan scan, List<KeyValueScanner> additionalScanners) throws IOException
IOException
public void prepareDelete(Delete delete) throws IOException
Region
prepareDelete
in interface Region
delete
- The passed delete is modified by this method. WARNING!IOException
public void delete(Delete delete) throws IOException
Region
delete
in interface Region
IOException
public void prepareDeleteTimestamps(Mutation mutation, Map<byte[],List<Cell>> familyMap, byte[] byteNow) throws IOException
Region
Caller should have the row and region locks.
prepareDeleteTimestamps
in interface Region
IOException
public void put(Put put) throws IOException
Region
put
in interface Region
IOException
public OperationStatus[] batchMutate(Mutation[] mutations, long nonceGroup, long nonce) throws IOException
Region
Note this supports only Put and Delete mutations and will ignore other types passed.
batchMutate
in interface Region
mutations
- the list of mutationsIOException
public OperationStatus[] batchMutate(Mutation[] mutations) throws IOException
IOException
public OperationStatus[] batchReplay(WALSplitter.MutationReplay[] mutations, long replaySeqId) throws IOException
Region
batchReplay
in interface Region
mutations
- mutations to replay.IOException
protected Durability getEffectiveDurability(Durability d)
public boolean checkAndMutate(byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Mutation w, boolean writeToWAL) throws IOException
Region
checkAndMutate
in interface Region
row
- to checkfamily
- column family to checkqualifier
- column qualifier to checkcompareOp
- the comparison operatorIOException
public boolean checkAndRowMutate(byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, RowMutations rm, boolean writeToWAL) throws IOException
Region
checkAndRowMutate
in interface Region
row
- to checkfamily
- column family to checkqualifier
- column qualifier to checkcompareOp
- the comparison operatorIOException
public void addRegionToSnapshot(HBaseProtos.SnapshotDescription desc, ForeignExceptionSnare exnSnare) throws IOException
ForeignExceptionSnare
arg. (In the future other cancellable HRegion methods could eventually add a
ForeignExceptionSnare
, or we could do something fancier).desc
- snapshot description objectexnSnare
- ForeignExceptionSnare that captures external exceptions in case we need to
bail out. This is allowed to be null and will just be ignored in that case.IOException
- if there is an external or internal error causing the snapshot to failpublic void updateCellTimestamps(Iterable<List<Cell>> cellItr, byte[] now) throws IOException
Region
updateCellTimestamps
in interface Region
IOException
protected void checkReadOnly() throws IOException
IOException
- Throws exception if region is in read-only mode.protected void checkReadsEnabled() throws IOException
IOException
public void setReadsEnabled(boolean readsEnabled)
public void checkFamilies(Collection<byte[]> families) throws NoSuchColumnFamilyException
Region
checkFamilies
in interface Region
NoSuchColumnFamilyException
public void checkTimestamps(Map<byte[],List<Cell>> familyMap, long now) throws FailedSanityCheckException
Region
checkTimestamps
in interface Region
now
- current timestampFailedSanityCheckException
protected long replayRecoveredEditsIfAny(Path regiondir, Map<byte[],Long> maxSeqIdInStores, CancelableProgressable reporter, MonitoredTask status) throws IOException
We can ignore any wal message that has a sequence ID that's equal to or lower than minSeqId. (Because we know such messages are already reflected in the HFiles.)
While this is running we are putting pressure on memory yet we are outside of our usual accounting because we are not yet an onlined region (this stuff is being run as part of Region initialization). This means that if we're up against global memory limits, we'll not be flagged to flush because we are not online. We can't be flushed by usual mechanisms anyways; we're not yet online so our relative sequenceids are not yet aligned with WAL sequenceids -- not till we come up online, post processing of split edits.
But to help relieve memory pressure, at least manage our own heap size flushing if are in excess of per-region limits. Flushing, though, we have to be careful and avoid using the regionserver/wal sequenceid. Its running on a different line to whats going on in here in this region context so if we crashed replaying these edits, but in the midst had a flush that used the regionserver wal with a sequenceid in excess of whats going on in here in this region and with its split editlogs, then we could miss edits the next time we go to recover. So, we have to flush inline, using seqids that make sense in a this single region context only -- until we online.
maxSeqIdInStores
- Any edit found in split editlogs needs to be in excess of
the maxSeqId for the store to be applied, else its skipped.minSeqId
if nothing added from editlogs.UnsupportedEncodingException
IOException
public boolean refreshStoreFiles() throws IOException
Region
refreshStoreFiles
in interface Region
IOException
protected boolean restoreEdit(Store s, Cell cell)
s
- Store to add edit too.cell
- Cell to add.protected HStore instantiateHStore(HColumnDescriptor family) throws IOException
IOException
public Store getStore(byte[] column)
Region
Use with caution. Exposed for use of fixup utilities.
public List<Store> getStores()
Region
Use with caution. Exposed for use of fixup utilities.
public List<String> getStoreFileList(byte[][] columns) throws IllegalArgumentException
getStoreFileList
in interface Region
IllegalArgumentException
public Region.RowLock getRowLock(byte[] row, boolean waitForLock) throws IOException
Region
getRowLock
in interface Region
waitForLock
- if true, will block until the lock is available.
Otherwise, just tries to obtain the lock and returns
false if unavailable.IOException
- if waitForLock was true and the lock could not be acquired after waitingprotected Region.RowLock getRowLockInternal(byte[] row, boolean waitForLock) throws IOException
IOException
public Region.RowLock getRowLock(byte[] row) throws IOException
IOException
- if the lock could not be acquired after waitingpublic void releaseRowLocks(List<Region.RowLock> rowLocks)
Region
releaseRowLocks
in interface Region
public boolean bulkLoadHFiles(Collection<Pair<byte[],String>> familyPaths, boolean assignSeqId, Region.BulkLoadListener bulkLoadListener) throws IOException
Region
bulkLoadHFiles
in interface Region
familyPaths
- List of PairbulkLoadListener
- Internal hooks enabling massaging/preparation of a
file about to be bulk loadedIOException
- if failed unrecoverably.public static HRegion createHRegion(HRegionInfo info, Path rootDir, Configuration conf, HTableDescriptor hTableDescriptor) throws IOException
WAL
for the created region. It
needs to be closed explicitly. Use getWAL()
to get
access. When done with a region created using this method, you will
need to explicitly close the WAL
it created too; it will not be
done for you. Not closing the wal will leave at least a daemon thread
running. Call closeHRegion(HRegion)
and it will do
necessary cleanup for you.info
- Info for region to create.rootDir
- Root directory for HBase instanceIOException
public static void closeHRegion(HRegion r) throws IOException
createHRegion(HRegionInfo, Path, Configuration, HTableDescriptor)
requires. This method will close the region and then close its
associated WAL
file. You can still use it if you call the other createHRegion,
the one that takes an WAL
instance but don't be surprised by the
call to the WAL.close()
on the WAL
the
HRegion was carrying.IOException
public static HRegion createHRegion(HRegionInfo info, Path rootDir, Configuration conf, HTableDescriptor hTableDescriptor, WAL wal, boolean initialize) throws IOException
WAL
for the created region needs to be closed explicitly.
Use getWAL()
to get access.info
- Info for region to create.rootDir
- Root directory for HBase instancewal
- shared WALinitialize
- - true to initialize the regionIOException
public static HRegion createHRegion(HRegionInfo info, Path rootDir, Configuration conf, HTableDescriptor hTableDescriptor, WAL wal, boolean initialize, boolean ignoreWAL) throws IOException
WAL
for the created region needs to be closed
explicitly, if it is not null.
Use getWAL()
to get access.info
- Info for region to create.rootDir
- Root directory for HBase instancewal
- shared WALinitialize
- - true to initialize the regionignoreWAL
- - true to skip generate new wal if it is null, mostly for createTableIOException
public static HRegion createHRegion(HRegionInfo info, Path rootDir, Path tableDir, Configuration conf, HTableDescriptor hTableDescriptor, WAL wal, boolean initialize, boolean ignoreWAL) throws IOException
WAL
for the created region needs to be closed
explicitly, if it is not null.
Use getWAL()
to get access.info
- Info for region to create.rootDir
- Root directory for HBase instancetableDir
- table directorywal
- shared WALinitialize
- - true to initialize the regionignoreWAL
- - true to skip generate new wal if it is null, mostly for createTableIOException
public static HRegion createHRegion(HRegionInfo info, Path rootDir, Configuration conf, HTableDescriptor hTableDescriptor, WAL wal) throws IOException
IOException
public static HRegion openHRegion(HRegionInfo info, HTableDescriptor htd, WAL wal, Configuration conf) throws IOException
info
- Info for region to be opened.wal
- WAL for region to use. This method will call
WAL#setSequenceNumber(long) passing the result of the call to
HRegion#getMinSequenceId() to ensure the wal id is properly kept
up. HRegionStore does this every time it opens a new region.IOException
public static HRegion openHRegion(HRegionInfo info, HTableDescriptor htd, WAL wal, Configuration conf, RegionServerServices rsServices, CancelableProgressable reporter) throws IOException
info
- Info for region to be openedhtd
- the table descriptorwal
- WAL for region to use. This method will call
WAL#setSequenceNumber(long) passing the result of the call to
HRegion#getMinSequenceId() to ensure the wal id is properly kept
up. HRegionStore does this every time it opens a new region.conf
- The Configuration object to use.rsServices
- An interface we can request flushes against.reporter
- An interface we can report progress against.IOException
public static HRegion openHRegion(Path rootDir, HRegionInfo info, HTableDescriptor htd, WAL wal, Configuration conf) throws IOException
rootDir
- Root directory for HBase instanceinfo
- Info for region to be opened.htd
- the table descriptorwal
- WAL for region to use. This method will call
WAL#setSequenceNumber(long) passing the result of the call to
HRegion#getMinSequenceId() to ensure the wal id is properly kept
up. HRegionStore does this every time it opens a new region.conf
- The Configuration object to use.IOException
public static HRegion openHRegion(Path rootDir, HRegionInfo info, HTableDescriptor htd, WAL wal, Configuration conf, RegionServerServices rsServices, CancelableProgressable reporter) throws IOException
rootDir
- Root directory for HBase instanceinfo
- Info for region to be opened.htd
- the table descriptorwal
- WAL for region to use. This method will call
WAL#setSequenceNumber(long) passing the result of the call to
HRegion#getMinSequenceId() to ensure the wal id is properly kept
up. HRegionStore does this every time it opens a new region.conf
- The Configuration object to use.rsServices
- An interface we can request flushes against.reporter
- An interface we can report progress against.IOException
public static HRegion openHRegion(Configuration conf, FileSystem fs, Path rootDir, HRegionInfo info, HTableDescriptor htd, WAL wal) throws IOException
conf
- The Configuration object to use.fs
- Filesystem to userootDir
- Root directory for HBase instanceinfo
- Info for region to be opened.htd
- the table descriptorwal
- WAL for region to use. This method will call
WAL#setSequenceNumber(long) passing the result of the call to
HRegion#getMinSequenceId() to ensure the wal id is properly kept
up. HRegionStore does this every time it opens a new region.IOException
public static HRegion openHRegion(Configuration conf, FileSystem fs, Path rootDir, HRegionInfo info, HTableDescriptor htd, WAL wal, RegionServerServices rsServices, CancelableProgressable reporter) throws IOException
conf
- The Configuration object to use.fs
- Filesystem to userootDir
- Root directory for HBase instanceinfo
- Info for region to be opened.htd
- the table descriptorwal
- WAL for region to use. This method will call
WAL#setSequenceNumber(long) passing the result of the call to
HRegion#getMinSequenceId() to ensure the wal id is properly kept
up. HRegionStore does this every time it opens a new region.rsServices
- An interface we can request flushes against.reporter
- An interface we can report progress against.IOException
public static HRegion openHRegion(Configuration conf, FileSystem fs, Path rootDir, Path tableDir, HRegionInfo info, HTableDescriptor htd, WAL wal, RegionServerServices rsServices, CancelableProgressable reporter) throws IOException
conf
- The Configuration object to use.fs
- Filesystem to userootDir
- Root directory for HBase instanceinfo
- Info for region to be opened.htd
- the table descriptorwal
- WAL for region to use. This method will call
WAL#setSequenceNumber(long) passing the result of the call to
HRegion#getMinSequenceId() to ensure the wal id is properly kept
up. HRegionStore does this every time it opens a new region.rsServices
- An interface we can request flushes against.reporter
- An interface we can report progress against.IOException
public static HRegion openHRegion(HRegion other, CancelableProgressable reporter) throws IOException
other
- original objectreporter
- An interface we can report progress against.IOException
public static Region openHRegion(Region other, CancelableProgressable reporter) throws IOException
IOException
protected HRegion openHRegion(CancelableProgressable reporter) throws IOException
this
IOException
public static void warmupHRegion(HRegionInfo info, HTableDescriptor htd, WAL wal, Configuration conf, RegionServerServices rsServices, CancelableProgressable reporter) throws IOException
IOException
public static void addRegionToMETA(HRegion meta, HRegion r) throws IOException
meta
region. Used by the HMaster bootstrap code adding
new table to hbase:meta table.meta
- hbase:meta HRegion to be updatedr
- HRegion to add to meta
IOException
@Deprecated public static Path getRegionDir(Path tabledir, String name)
tabledir
- qualified path for tablename
- ENCODED region name@Deprecated public static Path getRegionDir(Path rootdir, HRegionInfo info)
rootdir
- qualified path of HBase root directoryinfo
- HRegionInfo for the regionpublic static boolean rowIsInRange(HRegionInfo info, byte[] row)
info
- HRegionInfo that specifies the row rangerow
- row to be checkedpublic static boolean rowIsInRange(HRegionInfo info, byte[] row, int offset, short length)
public static HRegion mergeAdjacent(HRegion srcA, HRegion srcB) throws IOException
IOException
public static HRegion merge(HRegion a, HRegion b) throws IOException
a
- region ab
- region bIOException
public Result get(Get get) throws IOException
Region
get
in interface Region
get
- query parametersIOException
public List<Cell> get(Get get, boolean withCoprocessor) throws IOException
Region
get
in interface Region
get
- query parameterswithCoprocessor
- invoke coprocessor or not. We don't want to
always invoke cp.IOException
public void mutateRow(RowMutations rm) throws IOException
Region
mutateRow
in interface Region
rm
- object that specifies the set of mutations to perform atomicallyIOException
public void mutateRowsWithLocks(Collection<Mutation> mutations, Collection<byte[]> rowsToLock) throws IOException
mutateRowsWithLocks(Collection, Collection, long, long)
IOException
public void mutateRowsWithLocks(Collection<Mutation> mutations, Collection<byte[]> rowsToLock, long nonceGroup, long nonce) throws IOException
mutateRowsWithLocks
in interface Region
mutations
- The list of mutations to perform.
mutations
can contain operations for multiple rows.
Caller has to ensure that all rows are contained in this region.rowsToLock
- Rows to locknonceGroup
- Optional nonce group of the operation (client Id)nonce
- Optional nonce of the operation (unique random id to ensure "more idempotence")
If multiple rows are locked care should be taken that
rowsToLock
is sorted in order to avoid deadlocks.IOException
public ClientProtos.RegionLoadStats getRegionStats()
public void processRowsWithLocks(RowProcessor<?,?> processor) throws IOException
Region
processRowsWithLocks
in interface Region
processor
- The object defines the reads and writes to a row.IOException
public void processRowsWithLocks(RowProcessor<?,?> processor, long nonceGroup, long nonce) throws IOException
Region
processRowsWithLocks
in interface Region
processor
- The object defines the reads and writes to a row.nonceGroup
- Optional nonce group of the operation (client Id)nonce
- Optional nonce of the operation (unique random id to ensure "more idempotence")IOException
public void processRowsWithLocks(RowProcessor<?,?> processor, long timeout, long nonceGroup, long nonce) throws IOException
Region
processRowsWithLocks
in interface Region
processor
- The object defines the reads and writes to a row.timeout
- The timeout of the processor.process() execution
Use a negative number to switch off the time boundnonceGroup
- Optional nonce group of the operation (client Id)nonce
- Optional nonce of the operation (unique random id to ensure "more idempotence")IOException
public Result append(Append append) throws IOException
IOException
public Result append(Append append, long nonceGroup, long nonce) throws IOException
Region
append
in interface Region
IOException
public Result increment(Increment increment) throws IOException
IOException
public Result increment(Increment increment, long nonceGroup, long nonce) throws IOException
Region
increment
in interface Region
IOException
public long heapSize()
public boolean registerService(Service instance)
Region
Service
subclass as a coprocessor endpoint to
be available for handling
Region#execService(com.google.protobuf.RpcController,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.CoprocessorServiceCall)
} calls.
Only a single instance may be registered per region for a given Service
subclass (the
instances are keyed on com.google.protobuf.Descriptors.ServiceDescriptor#getFullName()
.
After the first registration, subsequent calls with the same service name will fail with
a return value of false
.
registerService
in interface Region
instance
- the Service
subclass instance to expose as a coprocessor endpointtrue
if the registration was successful, false
otherwisepublic Message execService(RpcController controller, ClientProtos.CoprocessorServiceCall call) throws IOException
Region
Service
method using
the registered protocol handlers. Service
implementations must be registered via the
Region#registerService(com.google.protobuf.Service)
method before they are available.execService
in interface Region
controller
- an RpcContoller
implementation to pass to the invoked servicecall
- a CoprocessorServiceCall
instance identifying the service, method,
and parameters for the method invocationMessage
instance containing the method's resultIOException
- if no registered service handler is found or an error
occurs during the invocationorg.apache.hadoop.hbase.regionserver.Region#registerService(com.google.protobuf.Service)
protected void prepareToSplit()
public byte[] checkSplit()
public int getCompactPriority()
public RegionCoprocessorHost getCoprocessorHost()
getCoprocessorHost
in interface Region
public void setCoprocessorHost(RegionCoprocessorHost coprocessorHost)
coprocessorHost
- the new coprocessor hostpublic void startRegionOperation() throws IOException
Region
Region.closeRegionOperation()
MUST then always be called after
the operation has completed, whether it succeeded or failed.
startRegionOperation
in interface Region
IOException
public void startRegionOperation(Region.Operation op) throws IOException
Region
Region.closeRegionOperation()
MUST then always be called after
the operation has completed, whether it succeeded or failed.
startRegionOperation
in interface Region
op
- The operation is about to be taken on the regionIOException
public void closeRegionOperation() throws IOException
Region
closeRegionOperation
in interface Region
IOException
public void closeRegionOperation(Region.Operation operation) throws IOException
Region.startRegionOperation(Operation)
IOException
public static void main(String[] args) throws IOException
./bin/hbase org.apache.hadoop.hbase.regionserver.HRegion
IOException
public long getOpenSeqNum()
getOpenSeqNum
in interface Region
public Map<byte[],Long> getMaxStoreSeqId()
getMaxStoreSeqId
in interface Region
public long getOldestSeqIdOfStore(byte[] familyName)
getOldestSeqIdOfStore
in interface Region
public AdminProtos.GetRegionInfoResponse.CompactionState getCompactionState()
getCompactionState
in interface Region
public void reportCompactionRequestStart(boolean isMajor)
public void reportCompactionRequestEnd(boolean isMajor, int numFiles, long filesSizeCompacted)
public AtomicLong getSequenceId()
sequenceId
comment.public void onConfigurationChange(Configuration conf)
ConfigurationManager
object when the Configuration
object is reloaded from disk.onConfigurationChange
in interface ConfigurationObserver
public void registerChildren(ConfigurationManager manager)
registerChildren
in interface PropagatingConfigurationObserver
manager
- : to register topublic void deregisterChildren(ConfigurationManager manager)
deregisterChildren
in interface PropagatingConfigurationObserver
manager
- : to deregister frompublic RegionSplitPolicy getSplitPolicy()