co.cask.cdap.data2.transaction

Class ForwardingTransactionAware

java.lang.Object

com.google.common.collect.ForwardingObject

co.cask.cdap.data2.transaction.ForwardingTransactionAware

All Implemented Interfaces:

co.cask.tephra.TransactionAware

public abstract class ForwardingTransactionAware
extends com.google.common.collect.ForwardingObject
implements co.cask.tephra.TransactionAware

A TransactionAware that forwards every methods to another TransactionAware.

Constructor Summary

Constructors

Constructor and Description
ForwardingTransactionAware()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	commitTx()
protected abstract co.cask.tephra.TransactionAware	delegate()
String	getTransactionAwareName()
Collection<byte[]>	getTxChanges()
void	postTxCommit()
boolean	rollbackTx()
void	startTx(co.cask.tephra.Transaction tx)
void	updateTx(co.cask.tephra.Transaction tx)

Methods inherited from class com.google.common.collect.ForwardingObject

toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ForwardingTransactionAware

public ForwardingTransactionAware()

Method Detail

delegate

protected abstract co.cask.tephra.TransactionAware delegate()

Specified by:

delegate in class com.google.common.collect.ForwardingObject

startTx

public void startTx(co.cask.tephra.Transaction tx)

Specified by:

startTx in interface co.cask.tephra.TransactionAware

updateTx

public void updateTx(co.cask.tephra.Transaction tx)

Specified by:

updateTx in interface co.cask.tephra.TransactionAware

getTxChanges

public Collection<byte[]> getTxChanges()

Specified by:

getTxChanges in interface co.cask.tephra.TransactionAware

commitTx

public boolean commitTx()
                 throws Exception

Specified by:

commitTx in interface co.cask.tephra.TransactionAware

Throws:

Exception

postTxCommit

public void postTxCommit()

Specified by:

postTxCommit in interface co.cask.tephra.TransactionAware

rollbackTx

public boolean rollbackTx()
                   throws Exception

Specified by:

rollbackTx in interface co.cask.tephra.TransactionAware

Throws:

Exception

getTransactionAwareName

public String getTransactionAwareName()

Specified by:

getTransactionAwareName in interface co.cask.tephra.TransactionAware