co.cask.cdap.data2.transaction

Class DistributedTransactionSystemClientService

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

co.cask.cdap.common.service.UncaughtExceptionIdleService

co.cask.cdap.data2.transaction.DistributedTransactionSystemClientService

All Implemented Interfaces:

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

public class DistributedTransactionSystemClientService
extends UncaughtExceptionIdleService
implements TransactionSystemClientService

A Service for Tephra's TransactionSystemClient that waits on startup for the transaction system to be available. Everything else is just delegated to a TransactionSystemClient.

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
DistributedTransactionSystemClientService(CConfiguration cConf, DiscoveryServiceClient discoveryServiceClient, 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()
protected org.slf4j.Logger	getUncaughtExceptionLogger()
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 co.cask.cdap.common.service.UncaughtExceptionIdleService

executor, newHandler

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

addListener, 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

DistributedTransactionSystemClientService

@Inject
public DistributedTransactionSystemClientService(CConfiguration cConf,
                                                DiscoveryServiceClient discoveryServiceClient,
                                                co.cask.tephra.TransactionSystemClient delegate)

Method Detail

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

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

getUncaughtExceptionLogger

protected org.slf4j.Logger getUncaughtExceptionLogger()

Specified by:

getUncaughtExceptionLogger in class UncaughtExceptionIdleService