org.apache.hadoop.hbase.coordination

Class ZkOpenRegionCoordination

java.lang.Object

org.apache.hadoop.hbase.coordination.ZkOpenRegionCoordination

All Implemented Interfaces:

OpenRegionCoordination

@InterfaceAudience.Private
public class ZkOpenRegionCoordination
extends Object
implements OpenRegionCoordination

ZK-based implementation of OpenRegionCoordination.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ZkOpenRegionCoordination.ZkOpenRegionDetails ZK-based implementation.

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.coordination.OpenRegionCoordination

OpenRegionCoordination.OpenRegionDetails

Constructor Summary

Constructors

Constructor and Description
ZkOpenRegionCoordination(CoordinatedStateManager coordination, ZooKeeperWatcher watcher)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	commitOpenOnMasterSide(AssignmentManager assignmentManager, HRegionInfo regionInfo, OpenRegionCoordination.OpenRegionDetails ord) Commits opening operation on HM side (steps required for "commit" are determined by coordination implementation).
OpenRegionCoordination.OpenRegionDetails	getDetailsForNonCoordinatedOpening() No ZK tracking will be performed for that case.
OpenRegionCoordination.OpenRegionDetails	parseFromProtoRequest(AdminProtos.OpenRegionRequest.RegionOpenInfo regionOpenInfo) Parse ZK-related fields from request.
boolean	tickleOpening(OpenRegionCoordination.OpenRegionDetails ord, HRegionInfo regionInfo, RegionServerServices rsServices, String context) Update our OPENING state in zookeeper.
boolean	transitionFromOfflineToOpening(HRegionInfo regionInfo, OpenRegionCoordination.OpenRegionDetails ord) Transition ZK node from OFFLINE to OPENING.
boolean	transitionToOpened(HRegion r, OpenRegionCoordination.OpenRegionDetails ord) Tries to move regions to OPENED state.
boolean	tryTransitionFromOfflineToFailedOpen(RegionServerServices rsServices, HRegionInfo hri, OpenRegionCoordination.OpenRegionDetails ord) Try to transition to open.
boolean	tryTransitionFromOpeningToFailedOpen(HRegionInfo hri, OpenRegionCoordination.OpenRegionDetails ord) This is not guaranteed to succeed, we just do our best.

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkOpenRegionCoordination

public ZkOpenRegionCoordination(CoordinatedStateManager coordination,
                        ZooKeeperWatcher watcher)

Method Detail

transitionToOpened

public boolean transitionToOpened(HRegion r,
                         OpenRegionCoordination.OpenRegionDetails ord)
                           throws IOException

Description copied from interface: OpenRegionCoordination

Tries to move regions to OPENED state.

Specified by:

transitionToOpened in interface OpenRegionCoordination

Parameters:

r - Region we're working on.

ord - details about region opening task

Returns:

whether znode is successfully transitioned to OPENED state.

Throws:

IOException

transitionFromOfflineToOpening

public boolean transitionFromOfflineToOpening(HRegionInfo regionInfo,
                                     OpenRegionCoordination.OpenRegionDetails ord)

Transition ZK node from OFFLINE to OPENING.

Specified by:

transitionFromOfflineToOpening in interface OpenRegionCoordination

Parameters:

regionInfo - region info instance

ord - - instance of open region details, for ZK implementation will include version Of OfflineNode that needs to be compared before changing the node's state from OFFLINE

Returns:

True if successful transition.

tickleOpening

public boolean tickleOpening(OpenRegionCoordination.OpenRegionDetails ord,
                    HRegionInfo regionInfo,
                    RegionServerServices rsServices,
                    String context)

Update our OPENING state in zookeeper. Do this so master doesn't timeout this region-in-transition. We may lose the znode ownership during the open. Currently its too hard interrupting ongoing region open. Just let it complete and check we still have the znode after region open.

Specified by:

tickleOpening in interface OpenRegionCoordination

Parameters:

context - Some context to add to logs if failure

ord - details about opening task.

regionInfo - region we're working on.

rsServices - instance of RegionServerrServices

Returns:

True if successful transition.

tryTransitionFromOfflineToFailedOpen

public boolean tryTransitionFromOfflineToFailedOpen(RegionServerServices rsServices,
                                           HRegionInfo hri,
                                           OpenRegionCoordination.OpenRegionDetails ord)

Try to transition to open. This is not guaranteed to succeed, we just do our best.

Specified by:

tryTransitionFromOfflineToFailedOpen in interface OpenRegionCoordination

Parameters:

rsServices -

hri - Region we're working on.

ord - Details about region open task

Returns:

whether znode is successfully transitioned to FAILED_OPEN state.

tryTransitionFromOpeningToFailedOpen

public boolean tryTransitionFromOpeningToFailedOpen(HRegionInfo hri,
                                           OpenRegionCoordination.OpenRegionDetails ord)

This is not guaranteed to succeed, we just do our best.

Specified by:

tryTransitionFromOpeningToFailedOpen in interface OpenRegionCoordination

Parameters:

hri - Region we're working on.

ord - details about region opening task

Returns:

whether znode is successfully transitioned to FAILED_OPEN state.

parseFromProtoRequest

public OpenRegionCoordination.OpenRegionDetails parseFromProtoRequest(AdminProtos.OpenRegionRequest.RegionOpenInfo regionOpenInfo)

Parse ZK-related fields from request.

Specified by:

parseFromProtoRequest in interface OpenRegionCoordination

Returns:

instance of OpenRegionDetails.

getDetailsForNonCoordinatedOpening

public OpenRegionCoordination.OpenRegionDetails getDetailsForNonCoordinatedOpening()

No ZK tracking will be performed for that case. This method should be used when we want to construct CloseRegionDetails, but don't want any coordination on that (when it's initiated by regionserver), so no znode state transitions will be performed.

Specified by:

getDetailsForNonCoordinatedOpening in interface OpenRegionCoordination

commitOpenOnMasterSide

public boolean commitOpenOnMasterSide(AssignmentManager assignmentManager,
                             HRegionInfo regionInfo,
                             OpenRegionCoordination.OpenRegionDetails ord)

Description copied from interface: OpenRegionCoordination

Commits opening operation on HM side (steps required for "commit" are determined by coordination implementation).

Specified by:

commitOpenOnMasterSide in interface OpenRegionCoordination

Returns:

true if committed successfully, false otherwise.