co.cask.cdap.test

Class RevealingTxSystemClient

java.lang.Object

co.cask.cdap.test.RevealingTxSystemClient

All Implemented Interfaces:

org.apache.tephra.TransactionSystemClient

public class RevealingTxSystemClient
extends Object
implements org.apache.tephra.TransactionSystemClient

A TransactionSystemClient that creates transaction objects with additional fields for validation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RevealingTxSystemClient.RevealingTransaction This transaction class allows us to return additional details about the transaction to the client.

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Method Detail

startLong

public org.apache.tephra.Transaction startLong()

Specified by:

startLong in interface org.apache.tephra.TransactionSystemClient

startShort

public org.apache.tephra.Transaction startShort()

Specified by:

startShort in interface org.apache.tephra.TransactionSystemClient

startShort

public org.apache.tephra.Transaction startShort(int timeout)

Specified by:

startShort in interface org.apache.tephra.TransactionSystemClient

canCommit

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

Specified by:

canCommit in interface org.apache.tephra.TransactionSystemClient

Throws:

org.apache.tephra.TransactionNotInProgressException

commit

public boolean commit(org.apache.tephra.Transaction tx)
               throws org.apache.tephra.TransactionNotInProgressException

Specified by:

commit in interface org.apache.tephra.TransactionSystemClient

Throws:

org.apache.tephra.TransactionNotInProgressException

abort

public void abort(org.apache.tephra.Transaction tx)

Specified by:

abort in interface org.apache.tephra.TransactionSystemClient

invalidate

public boolean invalidate(long tx)

Specified by:

invalidate in interface org.apache.tephra.TransactionSystemClient

checkpoint

public org.apache.tephra.Transaction checkpoint(org.apache.tephra.Transaction tx)
                                         throws org.apache.tephra.TransactionNotInProgressException

Specified by:

checkpoint in interface org.apache.tephra.TransactionSystemClient

Throws:

org.apache.tephra.TransactionNotInProgressException

getSnapshotInputStream

public InputStream getSnapshotInputStream()
                                   throws org.apache.tephra.TransactionCouldNotTakeSnapshotException

Specified by:

getSnapshotInputStream in interface org.apache.tephra.TransactionSystemClient

Throws:

org.apache.tephra.TransactionCouldNotTakeSnapshotException

status

public String status()

Specified by:

status in interface org.apache.tephra.TransactionSystemClient

resetState

public void resetState()

Specified by:

resetState in interface org.apache.tephra.TransactionSystemClient

truncateInvalidTx

public boolean truncateInvalidTx(Set<Long> invalidTxIds)

Specified by:

truncateInvalidTx in interface org.apache.tephra.TransactionSystemClient

truncateInvalidTxBefore

public boolean truncateInvalidTxBefore(long time)
                                throws org.apache.tephra.InvalidTruncateTimeException

Specified by:

truncateInvalidTxBefore in interface org.apache.tephra.TransactionSystemClient

Throws:

org.apache.tephra.InvalidTruncateTimeException

getInvalidSize

public int getInvalidSize()

Specified by:

getInvalidSize in interface org.apache.tephra.TransactionSystemClient