org.apache.hadoop.hbase.coordination

Class ZkCloseRegionCoordination

java.lang.Object

org.apache.hadoop.hbase.coordination.ZkCloseRegionCoordination

All Implemented Interfaces:

CloseRegionCoordination

@InterfaceAudience.Private
public class ZkCloseRegionCoordination
extends Object
implements CloseRegionCoordination

ZK-based implementation of CloseRegionCoordination.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ZkCloseRegionCoordination.ZkCloseRegionDetails ZK-based implementation.

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

CloseRegionCoordination.CloseRegionDetails

Constructor Summary

Constructors

Constructor and Description
ZkCloseRegionCoordination(CoordinatedStateManager csm, ZooKeeperWatcher watcher)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	checkClosingState(HRegionInfo regionInfo, CloseRegionCoordination.CloseRegionDetails crd) In ZK-based version we're checking for bad znode state, e.g.
CloseRegionCoordination.CloseRegionDetails	getDetaultDetails() No ZK tracking will be performed for that case.
CloseRegionCoordination.CloseRegionDetails	parseFromProtoRequest(AdminProtos.CloseRegionRequest request) Parse ZK-related fields from request.
void	setClosedState(HRegion region, ServerName sn, CloseRegionCoordination.CloseRegionDetails crd) In ZK-based version we do some znodes transitioning.

Methods inherited from class java.lang.Object

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

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(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