Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

• coordination

  private CoordinatedStateManager coordination

• watcher

  private final ZooKeeperWatcher watcher

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.

• isGoodVersion

  private boolean isGoodVersion(ZkOpenRegionCoordination.ZkOpenRegionDetails zkOrd)

• 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(org.apache.hadoop.hbase.protobuf.generated.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.

• deleteOpenedNode

  private boolean deleteOpenedNode(HRegionInfo regionInfo,
                         OpenRegionCoordination.OpenRegionDetails ord)

• debugLog

  private void debugLog(HRegionInfo region,
              String string)

• isRegionStillOpening

  private boolean isRegionStillOpening(HRegionInfo regionInfo,
                             RegionServerServices rsServices)