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.
|
boolean |
ZkOpenRegionCoordination.tickleOpening(OpenRegionCoordination.OpenRegionDetails ord,
HRegionInfo regionInfo,
RegionServerServices rsServices,
String context)
Update our OPENING state in zookeeper.
|
boolean |
OpenRegionCoordination.tickleOpening(OpenRegionCoordination.OpenRegionDetails ord,
HRegionInfo regionInfo,
RegionServerServices rsServices,
String context)
Heartbeats to prevent timeouts.
|
boolean |
ZkOpenRegionCoordination.tryTransitionFromOfflineToFailedOpen(RegionServerServices rsServices,
HRegionInfo hri,
OpenRegionCoordination.OpenRegionDetails ord)
Try to transition to open.
|
boolean |
OpenRegionCoordination.tryTransitionFromOfflineToFailedOpen(RegionServerServices rsServices,
HRegionInfo hri,
OpenRegionCoordination.OpenRegionDetails ord)
Tries transition region from offline to failed 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 |
RegionServerCoprocessorEnvironment.getRegionServerServices()
Gets the region server services.
|
RegionServerServices |
RegionCoprocessorEnvironment.getRegionServerServices() |
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 | Method and Description |
---|---|
void |
RegionServerFlushTableProcedureManager.initialize(RegionServerServices rss)
Initialize this region server flush procedure manager
Uses a zookeeper based member controller.
|
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 |
---|---|
protected RegionServerServices |
LogRoller.services |
Modifier and Type | Method and Description |
---|---|
RegionServerServices |
SplitTransactionImpl.getRegionServerServices() |
RegionServerServices |
SplitTransaction.getRegionServerServices()
Get the RegonServerServices of the server running the transaction or rollback
|
RegionServerServices |
RegionMergeTransactionImpl.getRegionServerServices() |
RegionServerServices |
RegionMergeTransaction.getRegionServerServices()
Get the RegonServerServices of the server running the transaction or rollback
|
Modifier and Type | Method and Description |
---|---|
PairOfSameType<Region> |
SplitTransactionImpl.execute(Server server,
RegionServerServices services) |
PairOfSameType<Region> |
SplitTransaction.execute(Server server,
RegionServerServices services)
Deprecated.
use #execute(Server, RegionServerServices, User)
|
HRegion |
RegionMergeTransactionImpl.execute(Server server,
RegionServerServices services)
Run the transaction.
|
Region |
RegionMergeTransaction.execute(Server server,
RegionServerServices services)
Deprecated.
use #execute(Server, RegionServerServices, User)
|
PairOfSameType<Region> |
SplitTransactionImpl.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
PairOfSameType<Region> |
SplitTransaction.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
HRegion |
RegionMergeTransactionImpl.execute(Server server,
RegionServerServices services,
User user) |
Region |
RegionMergeTransaction.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
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.
|
boolean |
RegionMergeTransactionImpl.prepare(RegionServerServices services)
Does checks on merge inputs.
|
boolean |
RegionMergeTransaction.prepare(RegionServerServices services)
Check merge inputs and prepare the transaction.
|
boolean |
SplitTransactionImpl.rollback(Server server,
RegionServerServices services) |
boolean |
SplitTransaction.rollback(Server server,
RegionServerServices services)
Deprecated.
use #rollback(Server, RegionServerServices, User)
|
boolean |
RegionMergeTransactionImpl.rollback(Server server,
RegionServerServices services) |
boolean |
RegionMergeTransaction.rollback(Server server,
RegionServerServices services)
Deprecated.
use #rollback(Server, RegionServerServices, User)
|
boolean |
SplitTransactionImpl.rollback(Server server,
RegionServerServices services,
User user) |
boolean |
SplitTransaction.rollback(Server server,
RegionServerServices services,
User user)
Roll back a failed transaction
|
boolean |
RegionMergeTransactionImpl.rollback(Server server,
RegionServerServices services,
User user) |
boolean |
RegionMergeTransaction.rollback(Server server,
RegionServerServices services,
User user)
Roll back a failed transaction
|
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.
|
LogRoller(Server server,
RegionServerServices services) |
RegionCoprocessorHost(Region region,
RegionServerServices rsServices,
org.apache.hadoop.conf.Configuration conf)
Constructor
|
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 |
PressureAwareCompactionThroughputController.setup(RegionServerServices server) |
void |
NoLimitCompactionThroughputController.setup(RegionServerServices server) |
void |
CompactionThroughputController.setup(RegionServerServices server)
Setup controller for the given region server.
|
Modifier and Type | Field and Description |
---|---|
protected RegionServerServices |
FinishRegionRecoveringHandler.rss |
protected RegionServerServices |
OpenRegionHandler.rsServices |
Modifier and Type | Method and Description |
---|---|
void |
RegionServerSnapshotManager.initialize(RegionServerServices rss)
Create a default snapshot handler - uses a zookeeper based member controller.
|
Copyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.