Field Detail

• LOG

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

• FAILED_VERSION

  private static final int FAILED_VERSION

  See Also:

  Constant Field Values

• csm

  private CoordinatedStateManager csm

• watcher

  private final ZooKeeperWatcher watcher

Constructor Detail

• ZkCloseRegionCoordination

  public ZkCloseRegionCoordination(CoordinatedStateManager csm,
                           ZooKeeperWatcher watcher)

Method Detail

• checkClosingState

  public boolean checkClosingState(HRegionInfo regionInfo,
                          CloseRegionCoordination.CloseRegionDetails crd)

  In ZK-based version we're checking for bad znode state, e.g. if we're trying to delete the znode, and it's not ours (version doesn't match).

  Specified by:

  checkClosingState in interface CloseRegionCoordination

  Parameters:

  regionInfo - region being closed

  crd - details about closing operation

  Returns:

  true if caller shall proceed and close, false if need to abort closing.

• setClosedState

  public void setClosedState(HRegion region,
                    ServerName sn,
                    CloseRegionCoordination.CloseRegionDetails crd)

  In ZK-based version we do some znodes transitioning.

  Specified by:

  setClosedState in interface CloseRegionCoordination

  Parameters:

  region - region being closed

  sn - ServerName on which task runs

  crd - details about closing operation

• parseFromProtoRequest

  public CloseRegionCoordination.CloseRegionDetails parseFromProtoRequest(org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CloseRegionRequest request)

  Parse ZK-related fields from request.

  Specified by:

  parseFromProtoRequest in interface CloseRegionCoordination

  Returns:

  instance of CloseRegionDetails

• getDetaultDetails

  public CloseRegionCoordination.CloseRegionDetails getDetaultDetails()

  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:

  getDetaultDetails in interface CloseRegionCoordination

• setClosedState

  private boolean setClosedState(HRegion region,
                       ServerName sn,
                       ZkCloseRegionCoordination.ZkCloseRegionDetails zkCrd)

  Transition ZK node to CLOSED

  Parameters:

  region - HRegion instance being closed

  sn - ServerName on which task runs

  zkCrd - details about region closing operation.

  Returns:

  If the state is set successfully