org.apache.hadoop.hbase.coordination

Class ZkCoordinatedStateManager

java.lang.Object

org.apache.hadoop.hbase.coordination.BaseCoordinatedStateManager

org.apache.hadoop.hbase.coordination.ZkCoordinatedStateManager

All Implemented Interfaces:

CoordinatedStateManager

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class ZkCoordinatedStateManager
extends BaseCoordinatedStateManager

ZooKeeper-based implementation of CoordinatedStateManager.

Field Summary

Fields

Modifier and Type	Field and Description
protected CloseRegionCoordination	closeRegionCoordination
protected OpenRegionCoordination	openRegionCoordination
protected RegionMergeCoordination	regionMergeCoordination
protected Server	server
protected SplitLogManagerCoordination	splitLogManagerCoordination
protected SplitLogWorkerCoordination	splitLogWorkerCoordination
protected SplitTransactionCoordination	splitTransactionCoordination
protected ZooKeeperWatcher	watcher

Constructor Summary

Constructors

Constructor and Description
ZkCoordinatedStateManager()

Method Summary

Methods

Modifier and Type	Method and Description
CloseRegionCoordination	getCloseRegionCoordination() Method to retrieve coordination for closing region operations.
OpenRegionCoordination	getOpenRegionCoordination() Method to retrieve coordination for opening region operations.
RegionMergeCoordination	getRegionMergeCoordination() Method to retrieve coordination for region merge transaction
Server	getServer()
SplitLogManagerCoordination	getSplitLogManagerCoordination() Method to retrieve coordination for split log manager
SplitLogWorkerCoordination	getSplitLogWorkerCoordination() Method to retrieve coordination for split log worker
SplitTransactionCoordination	getSplitTransactionCoordination() Method to retrieve coordination for split transaction.
TableStateManager	getTableStateManager() Returns implementation of TableStateManager.
void	initialize(Server server) Initialize coordinated state management service.

Methods inherited from class org.apache.hadoop.hbase.coordination.BaseCoordinatedStateManager

start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

server

protected Server server

watcher

protected ZooKeeperWatcher watcher

splitTransactionCoordination

protected SplitTransactionCoordination splitTransactionCoordination

closeRegionCoordination

protected CloseRegionCoordination closeRegionCoordination

splitLogWorkerCoordination

protected SplitLogWorkerCoordination splitLogWorkerCoordination

splitLogManagerCoordination

protected SplitLogManagerCoordination splitLogManagerCoordination

openRegionCoordination

protected OpenRegionCoordination openRegionCoordination

regionMergeCoordination

protected RegionMergeCoordination regionMergeCoordination

Constructor Detail

ZkCoordinatedStateManager

public ZkCoordinatedStateManager()

Method Detail

initialize

public void initialize(Server server)

Description copied from interface: CoordinatedStateManager

Initialize coordinated state management service.

Specified by:

initialize in interface CoordinatedStateManager

Overrides:

initialize in class BaseCoordinatedStateManager

Parameters:

server - server instance to run within.

getServer

public Server getServer()

Specified by:

getServer in interface CoordinatedStateManager

Overrides:

getServer in class BaseCoordinatedStateManager

Returns:

instance of Server coordinated state manager runs within

getTableStateManager

public TableStateManager getTableStateManager()
                                       throws InterruptedException,
                                              CoordinatedStateException

Description copied from interface: CoordinatedStateManager

Returns implementation of TableStateManager.

Specified by:

getTableStateManager in interface CoordinatedStateManager

Specified by:

getTableStateManager in class BaseCoordinatedStateManager

Throws:

InterruptedException - if operation is interrupted

CoordinatedStateException - if error happens in underlying coordination mechanism

getSplitLogWorkerCoordination

public SplitLogWorkerCoordination getSplitLogWorkerCoordination()

Description copied from class: BaseCoordinatedStateManager

Method to retrieve coordination for split log worker

Specified by:

getSplitLogWorkerCoordination in class BaseCoordinatedStateManager

getSplitLogManagerCoordination

public SplitLogManagerCoordination getSplitLogManagerCoordination()

Description copied from class: BaseCoordinatedStateManager

Method to retrieve coordination for split log manager

Specified by:

getSplitLogManagerCoordination in class BaseCoordinatedStateManager

getSplitTransactionCoordination

public SplitTransactionCoordination getSplitTransactionCoordination()

Description copied from class: BaseCoordinatedStateManager

Method to retrieve coordination for split transaction.

Specified by:

getSplitTransactionCoordination in class BaseCoordinatedStateManager

getCloseRegionCoordination

public CloseRegionCoordination getCloseRegionCoordination()

Description copied from class: BaseCoordinatedStateManager

Method to retrieve coordination for closing region operations.

Specified by:

getCloseRegionCoordination in class BaseCoordinatedStateManager

getOpenRegionCoordination

public OpenRegionCoordination getOpenRegionCoordination()

Description copied from class: BaseCoordinatedStateManager

Method to retrieve coordination for opening region operations.

Specified by:

getOpenRegionCoordination in class BaseCoordinatedStateManager

getRegionMergeCoordination

public RegionMergeCoordination getRegionMergeCoordination()

Description copied from class: BaseCoordinatedStateManager

Method to retrieve coordination for region merge transaction

Specified by:

getRegionMergeCoordination in class BaseCoordinatedStateManager