org.apache.hadoop.hbase.coordination

Class ZKSplitTransactionCoordination

java.lang.Object

org.apache.hadoop.hbase.coordination.ZKSplitTransactionCoordination

All Implemented Interfaces:

SplitTransactionCoordination

Direct Known Subclasses:

TestSplitTransactionOnCluster.MockedSplitTransactionCoordination

public class ZKSplitTransactionCoordination
extends Object
implements SplitTransactionCoordination

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ZKSplitTransactionCoordination.ZkSplitTransactionDetails ZK-based implementation.

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

SplitTransactionCoordination.SplitTransactionDetails

Constructor Summary

Constructors

Constructor and Description
ZKSplitTransactionCoordination(CoordinatedStateManager coordinationProvider, ZooKeeperWatcher watcher)

Method Summary

Modifier and Type	Method and Description
void	clean(HRegionInfo hri) clean the split transaction
void	completeSplitTransaction(RegionServerServices services, Region a, Region b, SplitTransactionCoordination.SplitTransactionDetails std, Region parent) Finish off split transaction, transition the zknode
SplitTransactionCoordination.SplitTransactionDetails	getDefaultDetails()
int	processTransition(HRegionInfo p, HRegionInfo hri_a, HRegionInfo hri_b, ServerName sn, SplitTransactionCoordination.SplitTransactionDetails std) Required by AssignmentManager
void	startSplitTransaction(HRegion parent, ServerName serverName, HRegionInfo hri_a, HRegionInfo hri_b) Creates a new ephemeral node in the PENDING_SPLIT state for the specified region.
void	waitForSplitTransaction(RegionServerServices services, Region parent, HRegionInfo hri_a, HRegionInfo hri_b, SplitTransactionCoordination.SplitTransactionDetails sptd) Wait for the splitting node to be transitioned from pending_split to splitting by master.

Methods inherited from class java.lang.Object

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

Constructor Detail

ZKSplitTransactionCoordination

public ZKSplitTransactionCoordination(CoordinatedStateManager coordinationProvider,
                                      ZooKeeperWatcher watcher)

Method Detail

startSplitTransaction

public void startSplitTransaction(HRegion parent,
                                  ServerName serverName,
                                  HRegionInfo hri_a,
                                  HRegionInfo hri_b)
                           throws IOException

Creates a new ephemeral node in the PENDING_SPLIT state for the specified region. Create it ephemeral in case regionserver dies mid-split.

Does not transition nodes from other states. If a node already exists for this region, an Exception will be thrown.

Specified by:

startSplitTransaction in interface SplitTransactionCoordination

Parameters:

parent - region to be created as offline

serverName - server event originates from

hri_a - daughter region

hri_b - daughter region

Throws:

IOException

waitForSplitTransaction

public void waitForSplitTransaction(RegionServerServices services,
                                    Region parent,
                                    HRegionInfo hri_a,
                                    HRegionInfo hri_b,
                                    SplitTransactionCoordination.SplitTransactionDetails sptd)
                             throws IOException

Wait for the splitting node to be transitioned from pending_split to splitting by master. That's how we are sure master has processed the event and is good with us to move on. If we don't get any update, we periodically transition the node so that master gets the callback. If the node is removed or is not in pending_split state any more, we abort the split.

Specified by:

waitForSplitTransaction in interface SplitTransactionCoordination

Parameters:

services - Used to online/offline regions.

parent - region

hri_a - daughter region

hri_b - daughter region

sptd - split transaction details

Throws:

IOException

completeSplitTransaction

public void completeSplitTransaction(RegionServerServices services,
                                     Region a,
                                     Region b,
                                     SplitTransactionCoordination.SplitTransactionDetails std,
                                     Region parent)
                              throws IOException

Finish off split transaction, transition the zknode

Specified by:

completeSplitTransaction in interface SplitTransactionCoordination

Parameters:

services - Used to online/offline regions.

a - daughter region

b - daughter region

std - split transaction details

parent -

Throws:

IOException - If thrown, transaction failed. Call SplitTransaction.rollback( Server, RegionServerServices)

clean

public void clean(HRegionInfo hri)

Description copied from interface: SplitTransactionCoordination

clean the split transaction

Specified by:

clean in interface SplitTransactionCoordination

Parameters:

hri - node to delete

getDefaultDetails

public SplitTransactionCoordination.SplitTransactionDetails getDefaultDetails()

Specified by:

getDefaultDetails in interface SplitTransactionCoordination

processTransition

public int processTransition(HRegionInfo p,
                             HRegionInfo hri_a,
                             HRegionInfo hri_b,
                             ServerName sn,
                             SplitTransactionCoordination.SplitTransactionDetails std)
                      throws IOException

Description copied from interface: SplitTransactionCoordination

Required by AssignmentManager

Specified by:

processTransition in interface SplitTransactionCoordination

Throws:

IOException