org.apache.hadoop.hbase.coordination

Interface SplitTransactionCoordination

All Known Implementing Classes:

ZKSplitTransactionCoordination

@InterfaceAudience.Private
public interface SplitTransactionCoordination

Coordination operations for split transaction. The split operation should be coordinated at the following stages: 1. start - all preparation/initialization for split transaction should be done there. 2. waitForSplitTransaction - the coordination should perform all logic related to split transaction and wait till it's finished 3. completeSplitTransaction - all steps that are required to complete the transaction. Called after PONR (point of no return)

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	SplitTransactionCoordination.SplitTransactionDetails Dummy interface for split transaction details.

Method Summary

Methods

Modifier and Type	Method and Description
void	clean(HRegionInfo hri) clean the split transaction
void	completeSplitTransaction(RegionServerServices services, Region first, Region second, SplitTransactionCoordination.SplitTransactionDetails std, Region parent) Finish off split transaction
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) init coordination for split transaction
void	waitForSplitTransaction(RegionServerServices services, Region parent, HRegionInfo hri_a, HRegionInfo hri_b, SplitTransactionCoordination.SplitTransactionDetails std) Wait while coordination process the transaction

Method Detail

getDefaultDetails

SplitTransactionCoordination.SplitTransactionDetails getDefaultDetails()

startSplitTransaction

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

init coordination for split transaction

Parameters:

parent - region to be created as offline

serverName - server event originates from

hri_a - daughter region

hri_b - daughter region

Throws:

IOException

waitForSplitTransaction

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

Wait while coordination process the transaction

Parameters:

services - Used to online/offline regions.

parent - region

hri_a - daughter region

hri_b - daughter region

std - split transaction details

Throws:

IOException

completeSplitTransaction

void completeSplitTransaction(RegionServerServices services,
                            Region first,
                            Region second,
                            SplitTransactionCoordination.SplitTransactionDetails std,
                            Region parent)
                              throws IOException

Finish off split transaction

Parameters:

services - Used to online/offline regions.

first - daughter region

second - daughter region

std - split transaction details

parent -

Throws:

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

clean

void clean(HRegionInfo hri)

clean the split transaction

Parameters:

hri - node to delete

processTransition

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

Required by AssignmentManager

Throws:

IOException