org.apache.hadoop.hbase.regionserver

Class SplitTransactionImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.SplitTransactionImpl

All Implemented Interfaces:

SplitTransaction

Direct Known Subclasses:

TestSplitTransactionOnCluster.MockedSplitTransaction

@InterfaceAudience.Private
public class SplitTransactionImpl
extends Object
implements SplitTransaction

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SplitTransactionImpl.JournalEntryImpl

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.regionserver.SplitTransaction

SplitTransaction.JournalEntry, SplitTransaction.SplitTransactionPhase, SplitTransaction.TransactionListener

Field Summary

Fields

Modifier and Type	Field and Description
SplitTransactionCoordination.SplitTransactionDetails	std

Constructor Summary

Constructors

Constructor and Description
SplitTransactionImpl(Region r, byte[] splitrow) Constructor

Method Summary

Modifier and Type	Method and Description
Put	addLocation(Put p, ServerName sn, long openSeqNum)
PairOfSameType<Region>	execute(Server server, RegionServerServices services) Run the transaction.
PairOfSameType<Region>	execute(Server server, RegionServerServices services, User user) Run the transaction.
List<SplitTransaction.JournalEntry>	getJournal() Get the journal for the transaction.
RegionServerServices	getRegionServerServices() Get the RegonServerServices of the server running the transaction or rollback
Server	getServer() Get the Server running the transaction or rollback
boolean	prepare() Does checks on split inputs.
SplitTransaction	registerTransactionListener(SplitTransaction.TransactionListener listener) Register a listener for transaction preparation, execution, and possibly rollback phases.
boolean	rollback(Server server, RegionServerServices services) Roll back a failed transaction
boolean	rollback(Server server, RegionServerServices services, User user) Roll back a failed transaction
PairOfSameType<Region>	stepsAfterPONR(Server server, RegionServerServices services, PairOfSameType<Region> regions) Deprecated.
PairOfSameType<Region>	stepsAfterPONR(Server server, RegionServerServices services, PairOfSameType<Region> regions, User user)
PairOfSameType<Region>	stepsBeforePONR(Server server, RegionServerServices services, boolean testing)

Methods inherited from class java.lang.Object

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

Field Detail

std

public SplitTransactionCoordination.SplitTransactionDetails std

Constructor Detail

SplitTransactionImpl

public SplitTransactionImpl(Region r,
                            byte[] splitrow)

Constructor

Parameters:

r - Region to split

splitrow - Row to split around

Method Detail

prepare

public boolean prepare()
                throws IOException

Does checks on split inputs.

Specified by:

prepare in interface SplitTransaction

Returns:

true if the region is splittable else false if it is not (e.g. its already closed, etc.).

Throws:

IOException

stepsBeforePONR

public PairOfSameType<Region> stepsBeforePONR(Server server,
                                              RegionServerServices services,
                                              boolean testing)
                                       throws IOException

Throws:

IOException

execute

public PairOfSameType<Region> execute(Server server,
                                      RegionServerServices services)
                               throws IOException

Description copied from interface: SplitTransaction

Run the transaction.

Specified by:

execute in interface SplitTransaction

Parameters:

server - Hosting server instance. Can be null when testing.

services - Used to online/offline regions.

Returns:

Regions created

Throws:

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

See Also:

SplitTransaction.rollback(Server, RegionServerServices)

execute

public PairOfSameType<Region> execute(Server server,
                                      RegionServerServices services,
                                      User user)
                               throws IOException

Run the transaction.

Specified by:

execute in interface SplitTransaction

Parameters:

server - Hosting server instance. Can be null when testing

services - Used to online/offline regions.

Returns:

Regions created

Throws:

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

IOException

See Also:

rollback(Server, RegionServerServices)

stepsAfterPONR

@Deprecated
public PairOfSameType<Region> stepsAfterPONR(Server server,
                                                         RegionServerServices services,
                                                         PairOfSameType<Region> regions)
                                                  throws IOException

Deprecated.

Throws:

IOException

stepsAfterPONR

public PairOfSameType<Region> stepsAfterPONR(Server server,
                                             RegionServerServices services,
                                             PairOfSameType<Region> regions,
                                             User user)
                                      throws IOException

Throws:

IOException

addLocation

public Put addLocation(Put p,
                       ServerName sn,
                       long openSeqNum)

rollback

public boolean rollback(Server server,
                        RegionServerServices services)
                 throws IOException

Description copied from interface: SplitTransaction

Roll back a failed transaction

Specified by:

rollback in interface SplitTransaction

Parameters:

server - Hosting server instance (May be null when testing).

Returns:

True if we successfully rolled back, false if we got to the point of no return and so now need to abort the server to minimize damage.

Throws:

IOException - If thrown, rollback failed. Take drastic action.

rollback

public boolean rollback(Server server,
                        RegionServerServices services,
                        User user)
                 throws IOException

Description copied from interface: SplitTransaction

Roll back a failed transaction

Specified by:

rollback in interface SplitTransaction

Parameters:

server - Hosting server instance (May be null when testing).

services -

Returns:

True if we successfully rolled back, false if we got to the point of no return and so now need to abort the server to minimize damage.

Throws:

IOException - If thrown, rollback failed. Take drastic action.

getJournal

public List<SplitTransaction.JournalEntry> getJournal()

Description copied from interface: SplitTransaction

Get the journal for the transaction.

Journal entries are an opaque type represented as JournalEntry. They can also provide useful debugging information via their toString method.

Specified by:

getJournal in interface SplitTransaction

Returns:

the transaction journal

registerTransactionListener

public SplitTransaction registerTransactionListener(SplitTransaction.TransactionListener listener)

Description copied from interface: SplitTransaction

Register a listener for transaction preparation, execution, and possibly rollback phases.

A listener can abort a transaction by throwing an exception.

Specified by:

registerTransactionListener in interface SplitTransaction

Parameters:

listener - the listener

Returns:

'this' for chaining

getServer

public Server getServer()

Description copied from interface: SplitTransaction

Get the Server running the transaction or rollback

Specified by:

getServer in interface SplitTransaction

Returns:

server instance

getRegionServerServices

public RegionServerServices getRegionServerServices()

Description copied from interface: SplitTransaction

Get the RegonServerServices of the server running the transaction or rollback

Specified by:

getRegionServerServices in interface SplitTransaction

Returns:

region server services