org.apache.tephra.distributed

Class TransactionServiceThriftHandler

java.lang.Object

org.apache.tephra.distributed.TransactionServiceThriftHandler

All Implemented Interfaces:

TTransactionServer.Iface, RPCServiceHandler

public class TransactionServiceThriftHandler
extends Object
implements TTransactionServer.Iface, RPCServiceHandler

The implementation of a thrift service for tx service. All operations arrive over the wire as Thrift objects.

Why all this conversion (wrap/unwrap), and not define all Operations themselves as Thrift objects?

• All the non-thrift executors would have to use the Thrift objects
• Thrift's object model is too restrictive: it has only limited inheritance and no overloading
• Thrift objects are bare-bone, all they have are getters, setters, and basic object methods.

Constructor Summary

Constructors

Constructor and Description
TransactionServiceThriftHandler(TransactionManager txManager, TransactionPruningService pruningService)

Method Summary

Modifier and Type	Method and Description
void	abortTx(TTransaction tx)
void	canCommitOrThrow(long txId, Set<ByteBuffer> changes)
TBoolean	canCommitTx(TTransaction tx, Set<ByteBuffer> changes)
TTransaction	checkpoint(TTransaction originalTx)
void	commitOrThrow(long txId, long wp)
TBoolean	commitTx(TTransaction tx)
void	destroy()
ByteBuffer	getSnapshot()
void	init()
boolean	invalidateTx(long tx)
int	invalidTxSize()
void	pruneNow()
void	resetState()
TTransaction	startLong()
TTransaction	startLongClientId(String clientId)
TTransaction	startShort()
TTransaction	startShortClientId(String clientId)
TTransaction	startShortTimeout(int timeout)
TTransaction	startShortWithClientIdAndTimeOut(String clientId, int timeout)
TTransaction	startShortWithTimeout(int timeout)
String	status()
TBoolean	truncateInvalidTx(Set<Long> txns)
TBoolean	truncateInvalidTxBefore(long time)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionServiceThriftHandler

public TransactionServiceThriftHandler(TransactionManager txManager,
                                       TransactionPruningService pruningService)

Method Detail

startLong

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

Specified by:

startLong in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

startShort

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

Specified by:

startShort in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

startLongClientId

public TTransaction startLongClientId(String clientId)
                               throws org.apache.thrift.TException

Specified by:

startLongClientId in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

startShortTimeout

public TTransaction startShortTimeout(int timeout)
                               throws org.apache.thrift.TException

Specified by:

startShortTimeout in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

startShortClientId

public TTransaction startShortClientId(String clientId)
                                throws org.apache.thrift.TException

Specified by:

startShortClientId in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

startShortWithClientIdAndTimeOut

public TTransaction startShortWithClientIdAndTimeOut(String clientId,
                                                     int timeout)
                                              throws org.apache.thrift.TException

Specified by:

startShortWithClientIdAndTimeOut in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

startShortWithTimeout

public TTransaction startShortWithTimeout(int timeout)
                                   throws org.apache.thrift.TException

Specified by:

startShortWithTimeout in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

canCommitTx

public TBoolean canCommitTx(TTransaction tx,
                            Set<ByteBuffer> changes)
                     throws org.apache.thrift.TException

Specified by:

canCommitTx in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

canCommitOrThrow

public void canCommitOrThrow(long txId,
                             Set<ByteBuffer> changes)
                      throws org.apache.thrift.TException

Specified by:

canCommitOrThrow in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

commitTx

public TBoolean commitTx(TTransaction tx)
                  throws org.apache.thrift.TException

Specified by:

commitTx in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

commitOrThrow

public void commitOrThrow(long txId,
                          long wp)
                   throws org.apache.thrift.TException

Specified by:

commitOrThrow in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

abortTx

public void abortTx(TTransaction tx)
             throws org.apache.thrift.TException

Specified by:

abortTx in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

invalidateTx

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

Specified by:

invalidateTx in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

getSnapshot

public ByteBuffer getSnapshot()
                       throws org.apache.thrift.TException

Specified by:

getSnapshot in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

resetState

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

Specified by:

resetState in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

status

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

Specified by:

status in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

truncateInvalidTx

public TBoolean truncateInvalidTx(Set<Long> txns)
                           throws org.apache.thrift.TException

Specified by:

truncateInvalidTx in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

truncateInvalidTxBefore

public TBoolean truncateInvalidTxBefore(long time)
                                 throws org.apache.thrift.TException

Specified by:

truncateInvalidTxBefore in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

invalidTxSize

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

Specified by:

invalidTxSize in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

checkpoint

public TTransaction checkpoint(TTransaction originalTx)
                        throws org.apache.thrift.TException

Specified by:

checkpoint in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

pruneNow

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

Specified by:

pruneNow in interface TTransactionServer.Iface

Throws:

org.apache.thrift.TException

init

public void init()
          throws Exception

Specified by:

init in interface RPCServiceHandler

Throws:

Exception

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface RPCServiceHandler

Throws:

Exception