| Modifier and Type | Method and Description |
|---|---|
void |
ZKSplitTransactionCoordination.completeSplitTransaction(RegionServerServices services,
Region a,
Region b,
SplitTransactionCoordination.SplitTransactionDetails std,
Region parent)
Finish off split transaction, transition the zknode
|
void |
SplitTransactionCoordination.completeSplitTransaction(RegionServerServices services,
Region first,
Region second,
SplitTransactionCoordination.SplitTransactionDetails std,
Region parent)
Finish off split transaction
|
void |
ZKSplitTransactionCoordination.waitForSplitTransaction(RegionServerServices services,
Region parent,
HRegionInfo hri_a,
HRegionInfo hri_b,
SplitTransactionCoordination.SplitTransactionDetails sptd)
Wait for the splitting node to be transitioned from pending_split to splitting by master.
|
void |
SplitTransactionCoordination.waitForSplitTransaction(RegionServerServices services,
Region parent,
HRegionInfo hri_a,
HRegionInfo hri_b,
SplitTransactionCoordination.SplitTransactionDetails std)
Wait while coordination process the transaction
|
| Modifier and Type | Method and Description |
|---|---|
Region |
RegionCoprocessorEnvironment.getRegion() |
| Modifier and Type | Method and Description |
|---|---|
void |
RegionServerObserver.postMerge(ObserverContext<RegionServerCoprocessorEnvironment> c,
Region regionA,
Region regionB,
Region mergedRegion)
called after the regions merge.
|
void |
BaseRegionServerObserver.postMerge(ObserverContext<RegionServerCoprocessorEnvironment> c,
Region regionA,
Region regionB,
Region mergedRegion) |
void |
RegionServerObserver.postMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB,
Region mergedRegion)
This will be called after PONR step as part of regions merge transaction.
|
void |
BaseRegionServerObserver.postMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB,
Region mergedRegion) |
void |
RegionServerObserver.postRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB)
This will be called after the roll back of the regions merge.
|
void |
BaseRegionServerObserver.postRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB) |
void |
RegionObserver.postSplit(ObserverContext<RegionCoprocessorEnvironment> c,
Region l,
Region r)
Deprecated.
Use postCompleteSplit() instead
|
void |
BaseRegionObserver.postSplit(ObserverContext<RegionCoprocessorEnvironment> e,
Region l,
Region r) |
void |
RegionServerObserver.preMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB)
Called before the regions merge.
|
void |
BaseRegionServerObserver.preMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB) |
void |
RegionServerObserver.preMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB,
List<Mutation> metaEntries)
This will be called before PONR step as part of regions merge transaction.
|
void |
BaseRegionServerObserver.preMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB,
List<Mutation> metaEntries) |
void |
RegionServerObserver.preRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB)
This will be called before the roll back of the regions merge.
|
void |
BaseRegionServerObserver.preRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB) |
| Modifier and Type | Field and Description |
|---|---|
private Region |
RegionStateStore.metaRegion |
| Modifier and Type | Field and Description |
|---|---|
(package private) Region |
FlushTableSubprocedure.RegionFlushTask.region |
| Modifier and Type | Field and Description |
|---|---|
private List<Region> |
FlushTableSubprocedure.regions |
| Modifier and Type | Method and Description |
|---|---|
private List<Region> |
RegionServerFlushTableProcedureManager.getRegionsToFlush(String table)
Get the list of regions to flush for the table on this server
It is possible that if a region moves somewhere between the calls
we'll miss the region.
|
| Constructor and Description |
|---|
FlushTableSubprocedure.RegionFlushTask(Region region) |
| Constructor and Description |
|---|
FlushTableSubprocedure(ProcedureMember member,
ForeignExceptionDispatcher errorListener,
long wakeFrequency,
long timeout,
List<Region> regions,
String table,
RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager) |
| Modifier and Type | Method and Description |
|---|---|
private OperationQuota |
RegionServerQuotaManager.checkQuota(Region region,
int numWrites,
int numReads,
int numScans)
Check the quota for the current (rpc-context) user.
|
OperationQuota |
RegionServerQuotaManager.checkQuota(Region region,
List<org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Action> actions)
Check the quota for the current (rpc-context) user.
|
OperationQuota |
RegionServerQuotaManager.checkQuota(Region region,
OperationQuota.OperationType type)
Check the quota for the current (rpc-context) user.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HRegion |
| Modifier and Type | Field and Description |
|---|---|
private Region |
RSRpcServices.RegionScannerHolder.r |
(package private) Region |
RegionCoprocessorHost.region
The region
|
private Region |
RegionCoprocessorHost.RegionEnvironment.region |
private Region |
RegionServerServices.PostOpenDeployContext.region |
private Region |
MemStoreFlusher.FlushRegionEntry.region |
| Modifier and Type | Field and Description |
|---|---|
protected Map<String,Region> |
HRegionServer.onlineRegions
Map of regions currently being served by this region server.
|
protected Map<String,Region> |
HRegionServer.recoveringRegions
Set of regions currently being in recovering state which means it can accept writes(edits from
previous failed region server) but not reads.
|
private Map<Region,MemStoreFlusher.FlushRegionEntry> |
MemStoreFlusher.regionsInQueue |
| Modifier and Type | Method and Description |
|---|---|
Region |
RegionMergeTransaction.execute(Server server,
RegionServerServices services)
Deprecated.
use #execute(Server, RegionServerServices, User)
|
Region |
RegionMergeTransaction.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
private Region |
MemStoreFlusher.getBiggestMemstoreOfRegionReplica(SortedMap<Long,Region> regionsBySize,
Set<Region> excludedRegions) |
private Region |
MemStoreFlusher.getBiggestMemstoreRegion(SortedMap<Long,Region> regionsBySize,
Set<Region> excludedRegions,
boolean checkStoreFileCount) |
Region |
OnlineRegions.getFromOnlineRegions(String encodedRegionName)
Return
Region instance. |
Region |
HRegionServer.getFromOnlineRegions(String encodedRegionName) |
Region |
HRegionServer.getOnlineRegion(byte[] regionName) |
Region |
RegionCoprocessorHost.RegionEnvironment.getRegion() |
Region |
RegionServerServices.PostOpenDeployContext.getRegion() |
protected Region |
HRegionServer.getRegion(byte[] regionName)
Protected utility method for safely obtaining an HRegion handle.
|
(package private) Region |
RSRpcServices.getRegion(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.RegionSpecifier regionSpecifier)
Find the HRegion based on a region specifier
|
protected Region |
HRegionServer.getRegionByEncodedName(byte[] regionName,
String encodedRegionName) |
Region |
HRegionServer.getRegionByEncodedName(String encodedRegionName) |
static Region |
HRegion.openHRegion(Region other,
CancelableProgressable reporter) |
| Modifier and Type | Method and Description |
|---|---|
(package private) PairOfSameType<Region> |
SplitTransactionImpl.createDaughters(Server server,
RegionServerServices services) |
(package private) PairOfSameType<Region> |
SplitTransactionImpl.createDaughters(Server server,
RegionServerServices services,
User user)
Prepare the regions and region files.
|
PairOfSameType<Region> |
SplitTransaction.execute(Server server,
RegionServerServices services)
Deprecated.
use #execute(Server, RegionServerServices, User)
|
PairOfSameType<Region> |
SplitTransactionImpl.execute(Server server,
RegionServerServices services) |
PairOfSameType<Region> |
SplitTransaction.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
PairOfSameType<Region> |
SplitTransactionImpl.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
(package private) SortedMap<Long,Region> |
HRegionServer.getCopyOfOnlineRegionsSortedBySize() |
List<Region> |
OnlineRegions.getOnlineRegions(TableName tableName)
Get all online regions of a table in this RS.
|
List<Region> |
HRegionServer.getOnlineRegions(TableName tableName)
Gets the online regions of the specified table.
|
Collection<Region> |
HRegionServer.getOnlineRegionsLocalContext()
For tests, web ui and metrics.
|
Map<String,Region> |
RegionServerServices.getRecoveringRegions() |
Map<String,Region> |
HRegionServer.getRecoveringRegions() |
PairOfSameType<Region> |
SplitTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
PairOfSameType<Region> regions)
Deprecated.
|
PairOfSameType<Region> |
SplitTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
PairOfSameType<Region> regions,
User user) |
PairOfSameType<Region> |
SplitTransactionImpl.stepsBeforePONR(Server server,
RegionServerServices services,
boolean testing) |
| Modifier and Type | Method and Description |
|---|---|
(package private) long |
RSRpcServices.addScanner(RegionScanner s,
Region r) |
void |
OnlineRegions.addToOnlineRegions(Region r)
Add to online regions.
|
void |
HRegionServer.addToOnlineRegions(Region region) |
private Result |
RSRpcServices.append(Region region,
OperationQuota quota,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutationProto m,
CellScanner cellScanner,
long nonceGroup)
Execute an append mutation.
|
private boolean |
RSRpcServices.checkAndRowMutate(Region region,
List<org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Action> actions,
CellScanner cellScanner,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator)
Mutate a list of rows atomically.
|
private boolean |
RSRpcServices.closeScanner(Region region,
RegionScanner scanner,
String scannerName) |
SplitTransaction |
SplitTransactionFactory.create(Region r,
byte[] splitrow)
Create a split transaction
|
RegionMergeTransactionImpl |
RegionMergeTransactionFactory.create(Region a,
Region b,
boolean forcible)
Create a merge transaction
|
private org.apache.hadoop.hbase.protobuf.generated.ClusterStatusProtos.RegionLoad |
HRegionServer.createRegionLoad(Region r,
org.apache.hadoop.hbase.protobuf.generated.ClusterStatusProtos.RegionLoad.Builder regionLoadBldr,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.RegionSpecifier.Builder regionSpecifier) |
private void |
RSRpcServices.doBatchOp(org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
Region region,
OperationQuota quota,
List<org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Action> mutations,
CellScanner cells)
Execute a list of Put/Delete mutations.
|
private List<CellScannable> |
RSRpcServices.doNonAtomicRegionMutation(Region region,
OperationQuota quota,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction actions,
CellScanner cellScanner,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
List<CellScannable> cellsToReturn,
long nonceGroup)
Run through the regionMutation
rm and per Mutation, do the work, and then when
done, add an instance of a ClientProtos.ResultOrException that corresponds to each Mutation. |
private OperationStatus[] |
RSRpcServices.doReplayBatchOp(Region region,
List<WALSplitter.MutationReplay> mutations,
long replaySeqId)
Execute a list of Put/Delete mutations.
|
private com.google.protobuf.Message |
RSRpcServices.execServiceOnRegion(Region region,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.CoprocessorServiceCall serviceCall) |
private boolean |
MemStoreFlusher.flushRegion(Region region,
boolean emergencyFlush,
boolean forceFlushAllStores)
Flush a region.
|
void |
HeapMemoryManager.HeapMemoryTunerChore.flushRequested(FlushType type,
Region region) |
void |
FlushRequestListener.flushRequested(FlushType type,
Region region)
Callback which will get called when a flush request is made for a region.
|
(package private) WAL |
RSRpcServices.getWAL(Region region) |
private Result |
RSRpcServices.increment(Region region,
OperationQuota quota,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutationProto mutation,
CellScanner cells,
long nonceGroup)
Execute an increment mutation.
|
private boolean |
MemStoreFlusher.isTooManyStoreFiles(Region region) |
private org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionLoadStats |
RSRpcServices.mutateRows(Region region,
List<org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Action> actions,
CellScanner cellScanner)
Mutate a list of rows atomically.
|
private void |
MemStoreFlusher.notifyFlushRequest(Region region,
boolean emergencyFlush) |
(package private) void |
SplitTransactionImpl.openDaughters(Server server,
RegionServerServices services,
Region a,
Region b)
Perform time consuming opening of the daughter regions.
|
static Region |
HRegion.openHRegion(Region other,
CancelableProgressable reporter) |
void |
RegionServerServices.postOpenDeployTasks(Region r)
Deprecated.
|
void |
HRegionServer.postOpenDeployTasks(Region r) |
void |
RegionCoprocessorHost.postSplit(Region l,
Region r)
Invoked just after a split
|
private boolean |
MemStoreFlusher.refreshStoreFilesAndReclaimMemory(Region region) |
boolean |
OnlineRegions.removeFromOnlineRegions(Region r,
ServerName destination)
This method removes Region corresponding to hri from the Map of onlineRegions.
|
boolean |
HRegionServer.removeFromOnlineRegions(Region r,
ServerName destination) |
CompactionRequest |
CompactSplitThread.requestCompaction(Region r,
Store s,
String why,
CompactionRequest request) |
CompactionRequest |
CompactionRequestor.requestCompaction(Region r,
Store s,
String why,
CompactionRequest request) |
CompactionRequest |
CompactSplitThread.requestCompaction(Region r,
Store s,
String why,
int priority,
CompactionRequest request,
User user) |
CompactionRequest |
CompactionRequestor.requestCompaction(Region r,
Store s,
String why,
int pri,
CompactionRequest request,
User user) |
List<CompactionRequest> |
CompactSplitThread.requestCompaction(Region r,
String why) |
List<CompactionRequest> |
CompactionRequestor.requestCompaction(Region r,
String why) |
List<CompactionRequest> |
CompactSplitThread.requestCompaction(Region r,
String why,
int p,
List<Pair<CompactionRequest,Store>> requests,
User user) |
List<CompactionRequest> |
CompactionRequestor.requestCompaction(Region r,
String why,
int pri,
List<Pair<CompactionRequest,Store>> requests,
User user) |
List<CompactionRequest> |
CompactSplitThread.requestCompaction(Region r,
String why,
List<Pair<CompactionRequest,Store>> requests) |
List<CompactionRequest> |
CompactionRequestor.requestCompaction(Region r,
String why,
List<Pair<CompactionRequest,Store>> requests) |
private CompactionRequest |
CompactSplitThread.requestCompactionInternal(Region r,
Store s,
String why,
int priority,
CompactionRequest request,
boolean selectNow,
User user) |
private List<CompactionRequest> |
CompactSplitThread.requestCompactionInternal(Region r,
String why,
int p,
List<Pair<CompactionRequest,Store>> requests,
boolean selectNow,
User user) |
void |
MemStoreFlusher.requestDelayedFlush(Region r,
long delay,
boolean forceFlushAllStores) |
void |
FlushRequester.requestDelayedFlush(Region region,
long delay,
boolean forceFlushAllStores)
Tell the listener the cache needs to be flushed after a delay
|
void |
MemStoreFlusher.requestFlush(Region r,
boolean forceFlushAllStores) |
void |
FlushRequester.requestFlush(Region region,
boolean forceFlushAllStores)
Tell the listener the cache needs to be flushed.
|
void |
CompactSplitThread.requestRegionsMerge(Region a,
Region b,
boolean forcible,
long masterSystemTime,
User user) |
boolean |
CompactSplitThread.requestSplit(Region r) |
void |
CompactSplitThread.requestSplit(Region r,
byte[] midKey) |
void |
CompactSplitThread.requestSplit(Region r,
byte[] midKey,
User user) |
void |
CompactSplitThread.requestSystemCompaction(Region r,
Store s,
String why) |
void |
CompactSplitThread.requestSystemCompaction(Region r,
String why) |
private CompactionContext |
CompactSplitThread.selectCompaction(Region r,
Store s,
int priority,
CompactionRequest request,
User user) |
private void |
HRegionServer.updateRecoveringRegionLastFlushedSequenceId(Region r)
A helper function to store the last flushed sequence Id with the previous failed RS for a
recovering region.
|
| Modifier and Type | Method and Description |
|---|---|
private Region |
MemStoreFlusher.getBiggestMemstoreOfRegionReplica(SortedMap<Long,Region> regionsBySize,
Set<Region> excludedRegions) |
private Region |
MemStoreFlusher.getBiggestMemstoreOfRegionReplica(SortedMap<Long,Region> regionsBySize,
Set<Region> excludedRegions) |
private Region |
MemStoreFlusher.getBiggestMemstoreRegion(SortedMap<Long,Region> regionsBySize,
Set<Region> excludedRegions,
boolean checkStoreFileCount) |
private Region |
MemStoreFlusher.getBiggestMemstoreRegion(SortedMap<Long,Region> regionsBySize,
Set<Region> excludedRegions,
boolean checkStoreFileCount) |
PairOfSameType<Region> |
SplitTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
PairOfSameType<Region> regions)
Deprecated.
|
PairOfSameType<Region> |
SplitTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
PairOfSameType<Region> regions,
User user) |
| Constructor and Description |
|---|
CompactSplitThread.CompactionRunner(Store store,
Region region,
CompactionContext compaction,
ThreadPoolExecutor parent,
User user) |
MemStoreFlusher.FlushRegionEntry(Region r,
boolean forceFlushAllStores) |
RegionCoprocessorHost.RegionEnvironment(Coprocessor impl,
int priority,
int seq,
org.apache.hadoop.conf.Configuration conf,
Region region,
RegionServerServices services,
ConcurrentMap<String,Object> sharedData)
Constructor
|
RegionCoprocessorHost(Region region,
RegionServerServices rsServices,
org.apache.hadoop.conf.Configuration conf)
Constructor
|
RegionMergeRequest(Region a,
Region b,
HRegionServer hrs,
boolean forcible,
long masterSystemTime,
User user) |
RegionMergeTransactionImpl(Region a,
Region b,
boolean forcible)
Constructor
|
RegionMergeTransactionImpl(Region a,
Region b,
boolean forcible,
long masterSystemTime)
Constructor
|
RegionServerServices.PostOpenDeployContext(Region region,
long masterSystemTime) |
RSRpcServices.RegionScannerHolder(RegionScanner s,
Region r) |
SplitRequest(Region region,
byte[] midKey,
HRegionServer hrs,
User user) |
SplitTransactionImpl(Region r,
byte[] splitrow)
Constructor
|
| Modifier and Type | Field and Description |
|---|---|
(package private) Region |
FlushSnapshotSubprocedure.RegionSnapshotTask.region |
| Modifier and Type | Field and Description |
|---|---|
private List<Region> |
FlushSnapshotSubprocedure.regions |
| Modifier and Type | Method and Description |
|---|---|
private List<Region> |
RegionServerSnapshotManager.getRegionsToSnapshot(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.SnapshotDescription snapshot)
Determine if the snapshot should be handled on this server
NOTE: This is racy -- the master expects a list of regionservers.
|
| Constructor and Description |
|---|
FlushSnapshotSubprocedure.RegionSnapshotTask(Region region) |
| Constructor and Description |
|---|
FlushSnapshotSubprocedure(ProcedureMember member,
ForeignExceptionDispatcher errorListener,
long wakeFrequency,
long timeout,
List<Region> regions,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.SnapshotDescription snapshot,
RegionServerSnapshotManager.SnapshotSubprocedurePool taskManager) |
| Modifier and Type | Field and Description |
|---|---|
private static SecureBulkLoadEndpoint.Consumer<Region> |
SecureBulkLoadEndpoint.fsCreatedListener |
| Modifier and Type | Method and Description |
|---|---|
Region |
AccessController.getRegion() |
private Region |
AccessController.getRegion(RegionCoprocessorEnvironment e) |
| Modifier and Type | Method and Description |
|---|---|
private TableName |
AccessController.getTableName(Region region) |
(package private) static boolean |
AccessControlLists.isAclRegion(Region region)
Returns
true if the given region is part of the _acl_
metadata table. |
(package private) static Map<byte[],com.google.common.collect.ListMultimap<String,TablePermission>> |
AccessControlLists.loadAll(Region aclRegion)
Loads all of the permission grants stored in a region of the
_acl_
table. |
void |
AccessController.postMerge(ObserverContext<RegionServerCoprocessorEnvironment> c,
Region regionA,
Region regionB,
Region mergedRegion) |
void |
AccessController.postMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB,
Region mergedRegion) |
void |
AccessController.postRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB) |
void |
AccessController.preMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB) |
void |
AccessController.preMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB,
List<Mutation> metaEntries) |
void |
AccessController.preRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
Region regionA,
Region regionB) |
| Modifier and Type | Method and Description |
|---|---|
(package private) static void |
SecureBulkLoadEndpoint.setFsCreatedListener(SecureBulkLoadEndpoint.Consumer<Region> listener) |
| Modifier and Type | Field and Description |
|---|---|
private Region |
DefaultVisibilityLabelServiceImpl.labelsRegion |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DefaultVisibilityLabelServiceImpl.addSystemLabel(Region region,
Map<String,Integer> labels,
Map<String,List<Integer>> userAuths) |
static Filter |
VisibilityUtils.createVisibilityLabelFilter(Region region,
Authorizations authorizations) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.