org.apache.tephra.distributed

Class TransactionServiceThriftClient

java.lang.Object

org.apache.tephra.distributed.TransactionServiceThriftClient

public class TransactionServiceThriftClient
extends Object

This class is a wrapper around the thrift tx service client, it takes Operations, converts them into thrift objects, calls the thrift client, and converts the results back to data fabric classes. This class also instruments the thrift calls with metrics.

Constructor Summary

Constructors

Constructor and Description
TransactionServiceThriftClient(org.apache.thrift.transport.TTransport transport) Constructor from an existing, connected thrift transport.

Method Summary

Modifier and Type	Method and Description
void	abort(Transaction tx)
void	canCommit(Transaction tx, Collection<byte[]> changeIds)
Transaction	checkpoint(Transaction tx)
void	close() close this client.
void	commit(long txId, long wp)
int	getInvalidSize()
InputStream	getSnapshotStream()
boolean	invalidate(long tx)
boolean	isValid()
void	pruneNow()
void	resetState()
Transaction	startLong()
Transaction	startLong(String clientId)
Transaction	startShort()
Transaction	startShort(int timeout)
Transaction	startShort(String clientId)
Transaction	startShort(String clientId, 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

Constructor Detail

TransactionServiceThriftClient

public TransactionServiceThriftClient(org.apache.thrift.transport.TTransport transport)

Constructor from an existing, connected thrift transport.

Parameters:

transport - the thrift transport layer. It must already be connected

Method Detail

close

public void close()

close this client. may be called multiple times

startLong

public Transaction startLong()
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

startLong

public Transaction startLong(String clientId)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

startShort

public Transaction startShort()
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

startShort

public Transaction startShort(int timeout)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

startShort

public Transaction startShort(String clientId)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

startShort

public Transaction startShort(String clientId,
                              int timeout)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

canCommit

public void canCommit(Transaction tx,
                      Collection<byte[]> changeIds)
               throws org.apache.thrift.TException,
                      TransactionNotInProgressException,
                      TransactionSizeException,
                      TransactionConflictException

Throws:

org.apache.thrift.TException

TransactionNotInProgressException

TransactionSizeException

TransactionConflictException

commit

public void commit(long txId,
                   long wp)
            throws org.apache.thrift.TException,
                   TransactionNotInProgressException,
                   TransactionConflictException

Throws:

org.apache.thrift.TException

TransactionNotInProgressException

TransactionConflictException

abort

public void abort(Transaction tx)
           throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

invalidate

public boolean invalidate(long tx)
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

checkpoint

public Transaction checkpoint(Transaction tx)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getSnapshotStream

public InputStream getSnapshotStream()
                              throws org.apache.thrift.TException,
                                     TransactionCouldNotTakeSnapshotException

Throws:

org.apache.thrift.TException

TransactionCouldNotTakeSnapshotException

status

public String status()
              throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

resetState

public void resetState()
                throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

truncateInvalidTx

public boolean truncateInvalidTx(Set<Long> invalidTxIds)
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

truncateInvalidTxBefore

public boolean truncateInvalidTxBefore(long time)
                                throws org.apache.thrift.TException,
                                       InvalidTruncateTimeException

Throws:

org.apache.thrift.TException

InvalidTruncateTimeException

getInvalidSize

public int getInvalidSize()
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

pruneNow

public void pruneNow()
              throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

isValid

public boolean isValid()