co.cask.cdap.data2.transaction

Class DelegatingTransactionSystemClientService

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

co.cask.cdap.data2.transaction.DelegatingTransactionSystemClientService

All Implemented Interfaces:

TransactionSystemClientService, co.cask.tephra.TransactionSystemClient, com.google.common.util.concurrent.Service

public class DelegatingTransactionSystemClientService
extends com.google.common.util.concurrent.AbstractIdleService
implements TransactionSystemClientService

Delegates all transaction methods to a TransactionSystemClient and does nothing during startup and shutdown.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
DelegatingTransactionSystemClientService(co.cask.tephra.TransactionSystemClient delegate)

Method Summary

Methods

Modifier and Type	Method and Description
void	abort(co.cask.tephra.Transaction tx)
boolean	canCommit(co.cask.tephra.Transaction tx, Collection<byte[]> changeIds)
co.cask.tephra.Transaction	checkpoint(co.cask.tephra.Transaction tx)
boolean	commit(co.cask.tephra.Transaction tx)
int	getInvalidSize()
InputStream	getSnapshotInputStream()
boolean	invalidate(long tx)
void	resetState()
protected void	shutDown()
co.cask.tephra.Transaction	startLong()
co.cask.tephra.Transaction	startShort()
co.cask.tephra.Transaction	startShort(int timeout)
protected void	startUp()
String	status()
boolean	truncateInvalidTx(Set<Long> invalidTxIds)
boolean	truncateInvalidTxBefore(long time)

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, executor, isRunning, start, startAndWait, state, stop, stopAndWait, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, isRunning, start, startAndWait, state, stop, stopAndWait

Constructor Detail

DelegatingTransactionSystemClientService

@Inject
public DelegatingTransactionSystemClientService(co.cask.tephra.TransactionSystemClient delegate)

Method Detail

startShort

public co.cask.tephra.Transaction startShort()

Specified by:

startShort in interface co.cask.tephra.TransactionSystemClient

startShort

public co.cask.tephra.Transaction startShort(int timeout)

Specified by:

startShort in interface co.cask.tephra.TransactionSystemClient

startLong

public co.cask.tephra.Transaction startLong()

Specified by:

startLong in interface co.cask.tephra.TransactionSystemClient

canCommit

public boolean canCommit(co.cask.tephra.Transaction tx,
                Collection<byte[]> changeIds)
                  throws co.cask.tephra.TransactionNotInProgressException

Specified by:

canCommit in interface co.cask.tephra.TransactionSystemClient

Throws:

co.cask.tephra.TransactionNotInProgressException

commit

public boolean commit(co.cask.tephra.Transaction tx)
               throws co.cask.tephra.TransactionNotInProgressException

Specified by:

commit in interface co.cask.tephra.TransactionSystemClient

Throws:

co.cask.tephra.TransactionNotInProgressException

abort

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

Specified by:

abort in interface co.cask.tephra.TransactionSystemClient

invalidate

public boolean invalidate(long tx)

Specified by:

invalidate in interface co.cask.tephra.TransactionSystemClient

checkpoint

public co.cask.tephra.Transaction checkpoint(co.cask.tephra.Transaction tx)
                                      throws co.cask.tephra.TransactionNotInProgressException

Specified by:

checkpoint in interface co.cask.tephra.TransactionSystemClient

Throws:

co.cask.tephra.TransactionNotInProgressException

getSnapshotInputStream

public InputStream getSnapshotInputStream()
                                   throws co.cask.tephra.TransactionCouldNotTakeSnapshotException

Specified by:

getSnapshotInputStream in interface co.cask.tephra.TransactionSystemClient

Throws:

co.cask.tephra.TransactionCouldNotTakeSnapshotException

status

public String status()

Specified by:

status in interface co.cask.tephra.TransactionSystemClient

resetState

public void resetState()

Specified by:

resetState in interface co.cask.tephra.TransactionSystemClient

truncateInvalidTx

public boolean truncateInvalidTx(Set<Long> invalidTxIds)

Specified by:

truncateInvalidTx in interface co.cask.tephra.TransactionSystemClient

truncateInvalidTxBefore

public boolean truncateInvalidTxBefore(long time)
                                throws co.cask.tephra.InvalidTruncateTimeException

Specified by:

truncateInvalidTxBefore in interface co.cask.tephra.TransactionSystemClient

Throws:

co.cask.tephra.InvalidTruncateTimeException

getInvalidSize

public int getInvalidSize()

Specified by:

getInvalidSize in interface co.cask.tephra.TransactionSystemClient

startUp

protected void startUp()
                throws Exception

Specified by:

startUp in class com.google.common.util.concurrent.AbstractIdleService

Throws:

Exception

shutDown

protected void shutDown()
                 throws Exception

Specified by:

shutDown in class com.google.common.util.concurrent.AbstractIdleService

Throws:

Exception