Package | Description |
---|---|
org.apache.hadoop.hbase.master.snapshot | |
org.apache.hadoop.hbase.procedure | |
org.apache.hadoop.hbase.procedure.flush |
Modifier and Type | Field and Description |
---|---|
private ProcedureCoordinator |
EnabledTableSnapshotHandler.coordinator |
private ProcedureCoordinator |
SnapshotManager.coordinator |
Modifier and Type | Method and Description |
---|---|
(package private) ProcedureCoordinator |
SnapshotManager.getCoordinator()
Returns distributed commit coordinator for all running snapshots
|
Constructor and Description |
---|
SnapshotManager(MasterServices master,
ProcedureCoordinator coordinator,
ExecutorService pool,
int sentinelCleanInterval)
Fully specify all necessary components of a snapshot manager.
|
Modifier and Type | Field and Description |
---|---|
private ProcedureCoordinator |
Procedure.coord |
protected ProcedureCoordinator |
ZKProcedureCoordinator.coordinator |
Modifier and Type | Method and Description |
---|---|
boolean |
ZKProcedureCoordinator.start(ProcedureCoordinator coordinator)
Start monitoring znodes in ZK - subclass hook to start monitoring znodes they are about.
|
boolean |
ProcedureCoordinatorRpcs.start(ProcedureCoordinator listener)
Initialize and start threads necessary to connect an implementation's rpc mechanisms.
|
Constructor and Description |
---|
Procedure(ProcedureCoordinator coord,
ForeignExceptionDispatcher monitor,
long wakeFreq,
long timeout,
String procName,
byte[] args,
List<String> expectedMembers)
Creates a procedure.
|
Procedure(ProcedureCoordinator coord,
long wakeFreq,
long timeout,
String procName,
byte[] args,
List<String> expectedMembers)
Create a procedure.
|
Modifier and Type | Field and Description |
---|---|
private ProcedureCoordinator |
MasterFlushTableProcedureManager.coordinator |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.