| Modifier and Type | Field and Description |
|---|---|
private RegionServerServices |
ZkSplitLogWorkerCoordination.server |
| Modifier and Type | Method and Description |
|---|---|
void |
ZkRegionMergeCoordination.completeRegionMergeTransaction(RegionServerServices services,
HRegionInfo mergedRegionInfo,
HRegion region_a,
HRegion region_b,
RegionMergeCoordination.RegionMergeDetails rmd,
HRegion mergedRegion) |
void |
RegionMergeCoordination.completeRegionMergeTransaction(RegionServerServices services,
HRegionInfo merged,
HRegion region_a,
HRegion region_b,
RegionMergeCoordination.RegionMergeDetails rmd,
HRegion mergedRegion)
Finish off merge transaction
|
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 |
ZkSplitLogWorkerCoordination.init(RegionServerServices server,
org.apache.hadoop.conf.Configuration conf,
SplitLogWorker.TaskExecutor splitExecutor,
SplitLogWorker worker)
Override setter from
SplitLogWorkerCoordination |
void |
SplitLogWorkerCoordination.init(RegionServerServices server,
org.apache.hadoop.conf.Configuration conf,
SplitLogWorker.TaskExecutor splitTaskExecutor,
SplitLogWorker worker)
Initialize internal values.
|
private boolean |
ZkOpenRegionCoordination.isRegionStillOpening(HRegionInfo regionInfo,
RegionServerServices rsServices) |
boolean |
OpenRegionCoordination.tickleOpening(OpenRegionCoordination.OpenRegionDetails ord,
HRegionInfo regionInfo,
RegionServerServices rsServices,
String context)
Heartbeats to prevent timeouts.
|
boolean |
ZkOpenRegionCoordination.tickleOpening(OpenRegionCoordination.OpenRegionDetails ord,
HRegionInfo regionInfo,
RegionServerServices rsServices,
String context)
Update our OPENING state in zookeeper.
|
boolean |
OpenRegionCoordination.tryTransitionFromOfflineToFailedOpen(RegionServerServices rsServices,
HRegionInfo hri,
OpenRegionCoordination.OpenRegionDetails ord)
Tries transition region from offline to failed open.
|
boolean |
ZkOpenRegionCoordination.tryTransitionFromOfflineToFailedOpen(RegionServerServices rsServices,
HRegionInfo hri,
OpenRegionCoordination.OpenRegionDetails ord)
Try to transition to open.
|
void |
ZkRegionMergeCoordination.waitForRegionMergeTransaction(RegionServerServices services,
HRegionInfo mergedRegionInfo,
HRegion region_a,
HRegion region_b,
RegionMergeCoordination.RegionMergeDetails details)
Wait for the merging node to be transitioned from pending_merge
to merging by master.
|
void |
RegionMergeCoordination.waitForRegionMergeTransaction(RegionServerServices services,
HRegionInfo mergedRegionInfo,
HRegion region_a,
HRegion region_b,
RegionMergeCoordination.RegionMergeDetails details)
Get everything ready for region merge
|
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 |
|---|---|
RegionServerServices |
RegionCoprocessorEnvironment.getRegionServerServices() |
RegionServerServices |
RegionServerCoprocessorEnvironment.getRegionServerServices()
Gets the region server services.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HMaster
HMaster is the "master server" for HBase.
|
static class |
HMasterCommandLine.LocalHMaster |
| Modifier and Type | Method and Description |
|---|---|
void |
RegionServerProcedureManagerHost.initialize(RegionServerServices rss) |
abstract void |
RegionServerProcedureManager.initialize(RegionServerServices rss)
Initialize a globally barriered procedure for region servers.
|
| Modifier and Type | Field and Description |
|---|---|
private RegionServerServices |
RegionServerFlushTableProcedureManager.rss |
| Modifier and Type | Method and Description |
|---|---|
void |
RegionServerFlushTableProcedureManager.initialize(RegionServerServices rss)
Initialize this region server flush procedure manager
Uses a zookeeper based member controller.
|
| Modifier and Type | Field and Description |
|---|---|
private RegionServerServices |
RegionServerQuotaManager.rsServices |
private RegionServerServices |
QuotaCache.rsServices |
| Constructor and Description |
|---|
QuotaCache(RegionServerServices rsServices) |
RegionServerQuotaManager(RegionServerServices rsServices) |
| Modifier and Type | Class and Description |
|---|---|
class |
HRegionServer
HRegionServer makes a set of HRegions available to clients.
|
| Modifier and Type | Field and Description |
|---|---|
private RegionServerServices |
RegionServerCoprocessorHost.RegionServerEnvironment.regionServerServices |
(package private) RegionServerServices |
RegionCoprocessorHost.rsServices
The region server services
|
private RegionServerServices |
RegionCoprocessorHost.RegionEnvironment.rsServices |
private RegionServerServices |
RegionServerCoprocessorHost.rsServices |
private RegionServerServices |
SplitTransactionImpl.rsServices |
private RegionServerServices |
RegionMergeTransactionImpl.rsServices |
(package private) RegionServerServices |
HRegion.rsServices |
private RegionServerServices |
SplitLogWorker.server |
protected RegionServerServices |
LogRoller.services |
| Modifier and Type | Method and Description |
|---|---|
RegionServerServices |
RegionCoprocessorHost.RegionEnvironment.getRegionServerServices() |
RegionServerServices |
RegionMergeTransaction.getRegionServerServices()
Get the RegonServerServices of the server running the transaction or rollback
|
RegionServerServices |
SplitTransaction.getRegionServerServices()
Get the RegonServerServices of the server running the transaction or rollback
|
RegionServerServices |
RegionServerCoprocessorHost.RegionServerEnvironment.getRegionServerServices() |
RegionServerServices |
SplitTransactionImpl.getRegionServerServices() |
RegionServerServices |
RegionMergeTransactionImpl.getRegionServerServices() |
(package private) RegionServerServices |
HRegion.getRegionServerServices() |
| Modifier and Type | Method and Description |
|---|---|
private Map<byte[],List<StoreFile>> |
RegionMergeTransactionImpl.closeAndOfflineRegion(RegionServerServices services,
HRegion region,
boolean isRegionA,
boolean testing)
Close the merging region and offline it in regionserver
|
(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.
|
(package private) HRegion |
RegionMergeTransactionImpl.createMergedRegion(Server server,
RegionServerServices services,
User user)
Prepare the merged region and region files.
|
Region |
RegionMergeTransaction.execute(Server server,
RegionServerServices services)
Deprecated.
use #execute(Server, RegionServerServices, User)
|
PairOfSameType<Region> |
SplitTransaction.execute(Server server,
RegionServerServices services)
Deprecated.
use #execute(Server, RegionServerServices, User)
|
PairOfSameType<Region> |
SplitTransactionImpl.execute(Server server,
RegionServerServices services) |
HRegion |
RegionMergeTransactionImpl.execute(Server server,
RegionServerServices services)
Run the transaction.
|
Region |
RegionMergeTransaction.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
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.
|
HRegion |
RegionMergeTransactionImpl.execute(Server server,
RegionServerServices services,
User user) |
(package private) boolean |
RegionMergeTransactionImpl.hasMergeQualifierInMeta(RegionServerServices services,
byte[] regionName)
Checks if the given region has merge qualifier in hbase:meta
|
(package private) static HRegion |
HRegion.newHRegion(org.apache.hadoop.fs.Path tableDir,
WAL wal,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.conf.Configuration conf,
HRegionInfo regionInfo,
HTableDescriptor htd,
RegionServerServices rsServices)
A utility method to create new instances of HRegion based on the
HConstants.REGION_IMPL configuration property. |
(package private) void |
SplitTransactionImpl.openDaughters(Server server,
RegionServerServices services,
Region a,
Region b)
Perform time consuming opening of the daughter regions.
|
static HRegion |
HRegion.openHRegion(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.fs.Path tableDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(HRegionInfo info,
HTableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(org.apache.hadoop.fs.Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
(package private) void |
RegionMergeTransactionImpl.openMergedRegion(Server server,
RegionServerServices services,
HRegion merged)
Perform time consuming opening of the merged region.
|
boolean |
RegionMergeTransaction.prepare(RegionServerServices services)
Check merge inputs and prepare the transaction.
|
boolean |
RegionMergeTransactionImpl.prepare(RegionServerServices services)
Does checks on merge inputs.
|
boolean |
RegionMergeTransaction.rollback(Server server,
RegionServerServices services)
Deprecated.
use #rollback(Server, RegionServerServices, User)
|
boolean |
SplitTransaction.rollback(Server server,
RegionServerServices services)
Deprecated.
use #rollback(Server, RegionServerServices, User)
|
boolean |
SplitTransactionImpl.rollback(Server server,
RegionServerServices services) |
boolean |
RegionMergeTransactionImpl.rollback(Server server,
RegionServerServices services) |
boolean |
RegionMergeTransaction.rollback(Server server,
RegionServerServices services,
User user)
Roll back a failed transaction
|
boolean |
SplitTransaction.rollback(Server server,
RegionServerServices services,
User user)
Roll back a failed transaction
|
boolean |
SplitTransactionImpl.rollback(Server server,
RegionServerServices services,
User user) |
boolean |
RegionMergeTransactionImpl.rollback(Server server,
RegionServerServices services,
User user) |
void |
RegionMergeTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
HRegion mergedRegion)
Deprecated.
|
void |
RegionMergeTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
HRegion mergedRegion,
User user) |
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) |
HRegion |
RegionMergeTransactionImpl.stepsBeforePONR(Server server,
RegionServerServices services,
boolean testing) |
static void |
HRegion.warmupHRegion(HRegionInfo info,
HTableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter) |
| Constructor and Description |
|---|
HRegion(HRegionFileSystem fs,
WAL wal,
org.apache.hadoop.conf.Configuration confParam,
HTableDescriptor htd,
RegionServerServices rsServices)
HRegion constructor.
|
HRegion(org.apache.hadoop.fs.Path tableDir,
WAL wal,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.conf.Configuration confParam,
HRegionInfo regionInfo,
HTableDescriptor htd,
RegionServerServices rsServices)
Deprecated.
Use other constructors.
|
LogRoller(Server server,
RegionServerServices services) |
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
|
RegionServerCoprocessorHost.RegionServerEnvironment(Class<?> implClass,
Coprocessor impl,
int priority,
int seq,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices services) |
RegionServerCoprocessorHost(RegionServerServices rsServices,
org.apache.hadoop.conf.Configuration conf) |
SplitLogWorker(Server hserver,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices server,
LastSequenceId sequenceIdChecker,
WALFactory factory) |
SplitLogWorker(Server hserver,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices server,
SplitLogWorker.TaskExecutor splitTaskExecutor) |
| Modifier and Type | Method and Description |
|---|---|
static CompactionThroughputController |
CompactionThroughputControllerFactory.create(RegionServerServices server,
org.apache.hadoop.conf.Configuration conf) |
void |
NoLimitCompactionThroughputController.setup(RegionServerServices server) |
void |
CompactionThroughputController.setup(RegionServerServices server)
Setup controller for the given region server.
|
void |
PressureAwareCompactionThroughputController.setup(RegionServerServices server) |
| Modifier and Type | Field and Description |
|---|---|
protected RegionServerServices |
FinishRegionRecoveringHandler.rss |
private RegionServerServices |
CloseRegionHandler.rsServices |
protected RegionServerServices |
OpenRegionHandler.rsServices |
private RegionServerServices |
OpenRegionHandler.PostOpenDeployTasksThread.services |
| Modifier and Type | Method and Description |
|---|---|
private static boolean |
OpenRegionHandler.isRegionStillOpening(HRegionInfo regionInfo,
RegionServerServices rsServices) |
| Modifier and Type | Field and Description |
|---|---|
private RegionServerServices |
RegionServerSnapshotManager.rss |
| Modifier and Type | Method and Description |
|---|---|
void |
RegionServerSnapshotManager.initialize(RegionServerServices rss)
Create a default snapshot handler - uses a zookeeper based member controller.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.