Uses of Class
org.apache.tephra.distributed.thrift.TTransaction

Packages that use TTransaction

Package	Description
org.apache.tephra.distributed	This package contains standalone server of the transaction system v2.
org.apache.tephra.distributed.thrift

Uses of TTransaction in org.apache.tephra.distributed

Methods in org.apache.tephra.distributed that return TTransaction

Modifier and Type	Method and Description
TTransaction	TransactionServiceThriftHandler.checkpoint(TTransaction originalTx)
TTransaction	TransactionServiceThriftHandler.startLong()
TTransaction	TransactionServiceThriftHandler.startLongClientId(String clientId)
TTransaction	TransactionServiceThriftHandler.startShort()
TTransaction	TransactionServiceThriftHandler.startShortClientId(String clientId)
TTransaction	TransactionServiceThriftHandler.startShortTimeout(int timeout)
TTransaction	TransactionServiceThriftHandler.startShortWithClientIdAndTimeOut(String clientId, int timeout)
TTransaction	TransactionServiceThriftHandler.startShortWithTimeout(int timeout)
static TTransaction	TransactionConverterUtils.wrap(Transaction tx)

Methods in org.apache.tephra.distributed with parameters of type TTransaction

Modifier and Type	Method and Description
void	TransactionServiceThriftHandler.abortTx(TTransaction tx)
TBoolean	TransactionServiceThriftHandler.canCommitTx(TTransaction tx, Set<ByteBuffer> changes)
TTransaction	TransactionServiceThriftHandler.checkpoint(TTransaction originalTx)
TBoolean	TransactionServiceThriftHandler.commitTx(TTransaction tx)
static Transaction	TransactionConverterUtils.unwrap(TTransaction thriftTx)

Uses of TTransaction in org.apache.tephra.distributed.thrift

Fields in org.apache.tephra.distributed.thrift declared as TTransaction

Modifier and Type	Field and Description
TTransaction	TTransactionServer.startLong_result.success
TTransaction	TTransactionServer.startShort_result.success
TTransaction	TTransactionServer.startLongClientId_result.success
TTransaction	TTransactionServer.startShortTimeout_result.success
TTransaction	TTransactionServer.startShortClientId_result.success
TTransaction	TTransactionServer.startShortWithClientIdAndTimeOut_result.success
TTransaction	TTransactionServer.startShortWithTimeout_result.success
TTransaction	TTransactionServer.checkpoint_result.success
TTransaction	TTransactionServer.canCommitTx_args.tx
TTransaction	TTransactionServer.commitTx_args.tx
TTransaction	TTransactionServer.abortTx_args.tx
TTransaction	TTransactionServer.checkpoint_args.tx

Methods in org.apache.tephra.distributed.thrift that return TTransaction

Modifier and Type	Method and Description
TTransaction	TTransactionServer.Iface.checkpoint(TTransaction tx)
TTransaction	TTransactionServer.Client.checkpoint(TTransaction tx)
TTransaction	TTransaction.deepCopy()
TTransaction	TTransactionServer.AsyncClient.startLong_call.getResult()
TTransaction	TTransactionServer.AsyncClient.startShort_call.getResult()
TTransaction	TTransactionServer.AsyncClient.startLongClientId_call.getResult()
TTransaction	TTransactionServer.AsyncClient.startShortTimeout_call.getResult()
TTransaction	TTransactionServer.AsyncClient.startShortClientId_call.getResult()
TTransaction	TTransactionServer.AsyncClient.startShortWithClientIdAndTimeOut_call.getResult()
TTransaction	TTransactionServer.AsyncClient.startShortWithTimeout_call.getResult()
TTransaction	TTransactionServer.AsyncClient.checkpoint_call.getResult()
TTransaction	TTransactionServer.startLong_result.getSuccess()
TTransaction	TTransactionServer.startShort_result.getSuccess()
TTransaction	TTransactionServer.startLongClientId_result.getSuccess()
TTransaction	TTransactionServer.startShortTimeout_result.getSuccess()
TTransaction	TTransactionServer.startShortClientId_result.getSuccess()
TTransaction	TTransactionServer.startShortWithClientIdAndTimeOut_result.getSuccess()
TTransaction	TTransactionServer.startShortWithTimeout_result.getSuccess()
TTransaction	TTransactionServer.checkpoint_result.getSuccess()
TTransaction	TTransactionServer.canCommitTx_args.getTx()
TTransaction	TTransactionServer.commitTx_args.getTx()
TTransaction	TTransactionServer.abortTx_args.getTx()
TTransaction	TTransactionServer.checkpoint_args.getTx()
TTransaction	TTransactionServer.Client.recv_checkpoint()
TTransaction	TTransactionServer.Client.recv_startLong()
TTransaction	TTransactionServer.Client.recv_startLongClientId()
TTransaction	TTransactionServer.Client.recv_startShort()
TTransaction	TTransactionServer.Client.recv_startShortClientId()
TTransaction	TTransactionServer.Client.recv_startShortTimeout()
TTransaction	TTransactionServer.Client.recv_startShortWithClientIdAndTimeOut()
TTransaction	TTransactionServer.Client.recv_startShortWithTimeout()
TTransaction	TTransaction.setCheckpointWritePointers(List<Long> checkpointWritePointers)
TTransaction	TTransaction.setFirstShort(long firstShort)
TTransaction	TTransaction.setInProgress(List<Long> inProgress)
TTransaction	TTransaction.setInvalids(List<Long> invalids)
TTransaction	TTransaction.setReadPointer(long readPointer)
TTransaction	TTransaction.setTransactionId(long transactionId)
TTransaction	TTransaction.setType(TTransactionType type)
TTransaction	TTransaction.setVisibilityLevel(TVisibilityLevel visibilityLevel)
TTransaction	TTransaction.setWritePointer(long writePointer)
TTransaction	TTransactionServer.Iface.startLong()
TTransaction	TTransactionServer.Client.startLong()
TTransaction	TTransactionServer.Iface.startLongClientId(String clientId)
TTransaction	TTransactionServer.Client.startLongClientId(String clientId)
TTransaction	TTransactionServer.Iface.startShort()
TTransaction	TTransactionServer.Client.startShort()
TTransaction	TTransactionServer.Iface.startShortClientId(String clientId)
TTransaction	TTransactionServer.Client.startShortClientId(String clientId)
TTransaction	TTransactionServer.Iface.startShortTimeout(int timeout)
TTransaction	TTransactionServer.Client.startShortTimeout(int timeout)
TTransaction	TTransactionServer.Iface.startShortWithClientIdAndTimeOut(String clientId, int timeout)
TTransaction	TTransactionServer.Client.startShortWithClientIdAndTimeOut(String clientId, int timeout)
TTransaction	TTransactionServer.Iface.startShortWithTimeout(int timeout)
TTransaction	TTransactionServer.Client.startShortWithTimeout(int timeout)

Methods in org.apache.tephra.distributed.thrift with parameters of type TTransaction

Modifier and Type	Method and Description
void	TTransactionServer.Iface.abortTx(TTransaction tx)
void	TTransactionServer.Client.abortTx(TTransaction tx)
void	TTransactionServer.AsyncIface.abortTx(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.abortTx_call> resultHandler)
void	TTransactionServer.AsyncClient.abortTx(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.abortTx_call> resultHandler)
TBoolean	TTransactionServer.Iface.canCommitTx(TTransaction tx, Set<ByteBuffer> changes)
TBoolean	TTransactionServer.Client.canCommitTx(TTransaction tx, Set<ByteBuffer> changes)
void	TTransactionServer.AsyncIface.canCommitTx(TTransaction tx, Set<ByteBuffer> changes, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.canCommitTx_call> resultHandler)
void	TTransactionServer.AsyncClient.canCommitTx(TTransaction tx, Set<ByteBuffer> changes, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.canCommitTx_call> resultHandler)
TTransaction	TTransactionServer.Iface.checkpoint(TTransaction tx)
TTransaction	TTransactionServer.Client.checkpoint(TTransaction tx)
void	TTransactionServer.AsyncIface.checkpoint(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.checkpoint_call> resultHandler)
void	TTransactionServer.AsyncClient.checkpoint(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.checkpoint_call> resultHandler)
TBoolean	TTransactionServer.Iface.commitTx(TTransaction tx)
TBoolean	TTransactionServer.Client.commitTx(TTransaction tx)
void	TTransactionServer.AsyncIface.commitTx(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.commitTx_call> resultHandler)
void	TTransactionServer.AsyncClient.commitTx(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.commitTx_call> resultHandler)
int	TTransaction.compareTo(TTransaction other)
boolean	TTransaction.equals(TTransaction that)
void	TTransactionServer.Client.send_abortTx(TTransaction tx)
void	TTransactionServer.Client.send_canCommitTx(TTransaction tx, Set<ByteBuffer> changes)
void	TTransactionServer.Client.send_checkpoint(TTransaction tx)
void	TTransactionServer.Client.send_commitTx(TTransaction tx)
TTransactionServer.startLong_result	TTransactionServer.startLong_result.setSuccess(TTransaction success)
TTransactionServer.startShort_result	TTransactionServer.startShort_result.setSuccess(TTransaction success)
TTransactionServer.startLongClientId_result	TTransactionServer.startLongClientId_result.setSuccess(TTransaction success)
TTransactionServer.startShortTimeout_result	TTransactionServer.startShortTimeout_result.setSuccess(TTransaction success)
TTransactionServer.startShortClientId_result	TTransactionServer.startShortClientId_result.setSuccess(TTransaction success)
TTransactionServer.startShortWithClientIdAndTimeOut_result	TTransactionServer.startShortWithClientIdAndTimeOut_result.setSuccess(TTransaction success)
TTransactionServer.startShortWithTimeout_result	TTransactionServer.startShortWithTimeout_result.setSuccess(TTransaction success)
TTransactionServer.checkpoint_result	TTransactionServer.checkpoint_result.setSuccess(TTransaction success)
TTransactionServer.canCommitTx_args	TTransactionServer.canCommitTx_args.setTx(TTransaction tx)
TTransactionServer.commitTx_args	TTransactionServer.commitTx_args.setTx(TTransaction tx)
TTransactionServer.abortTx_args	TTransactionServer.abortTx_args.setTx(TTransaction tx)
TTransactionServer.checkpoint_args	TTransactionServer.checkpoint_args.setTx(TTransaction tx)

Constructors in org.apache.tephra.distributed.thrift with parameters of type TTransaction

Constructor and Description
TTransaction(TTransaction other) Performs a deep copy on other.
TTransactionServer.abortTx_args(TTransaction tx)
TTransactionServer.AsyncClient.abortTx_call(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.abortTx_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport)
TTransactionServer.AsyncClient.canCommitTx_call(TTransaction tx, Set<ByteBuffer> changes, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.canCommitTx_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport)
TTransactionServer.AsyncClient.checkpoint_call(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.checkpoint_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport)
TTransactionServer.AsyncClient.commitTx_call(TTransaction tx, org.apache.thrift.async.AsyncMethodCallback<TTransactionServer.AsyncClient.commitTx_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport)
TTransactionServer.canCommitTx_args(TTransaction tx, Set<ByteBuffer> changes)
TTransactionServer.checkpoint_args(TTransaction tx)
TTransactionServer.checkpoint_result(TTransaction success, TTransactionNotInProgressException e)
TTransactionServer.commitTx_args(TTransaction tx)
TTransactionServer.startLong_result(TTransaction success)
TTransactionServer.startLongClientId_result(TTransaction success, TGenericException e)
TTransactionServer.startShort_result(TTransaction success)
TTransactionServer.startShortClientId_result(TTransaction success, TGenericException e)
TTransactionServer.startShortTimeout_result(TTransaction success)
TTransactionServer.startShortWithClientIdAndTimeOut_result(TTransaction success, TGenericException e)
TTransactionServer.startShortWithTimeout_result(TTransaction success, TGenericException e)