Package | Description |
---|---|
org.apache.tephra.distributed |
This package contains standalone server of the transaction system v2.
|
org.apache.tephra.distributed.thrift |
Modifier and Type | Method and Description |
---|---|
TTransaction |
TransactionServiceThriftHandler.checkpoint(TTransaction originalTx) |
TTransaction |
TransactionServiceThriftHandler.startLong() |
TTransaction |
TransactionServiceThriftHandler.startShort() |
TTransaction |
TransactionServiceThriftHandler.startShortTimeout(int timeout) |
static TTransaction |
TransactionConverterUtils.wrap(Transaction tx) |
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) |
Modifier and Type | Field and Description |
---|---|
TTransaction |
TTransactionServer.startLong_result.success |
TTransaction |
TTransactionServer.startShort_result.success |
TTransaction |
TTransactionServer.startShortTimeout_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 |
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.startShortTimeout_call.getResult() |
TTransaction |
TTransactionServer.AsyncClient.checkpoint_call.getResult() |
TTransaction |
TTransactionServer.startLong_result.getSuccess() |
TTransaction |
TTransactionServer.startShort_result.getSuccess() |
TTransaction |
TTransactionServer.startShortTimeout_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_startShort() |
TTransaction |
TTransactionServer.Client.recv_startShortTimeout() |
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.startShort() |
TTransaction |
TTransactionServer.Client.startShort() |
TTransaction |
TTransactionServer.Iface.startShortTimeout(int timeout) |
TTransaction |
TTransactionServer.Client.startShortTimeout(int timeout) |
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.startShortTimeout_result |
TTransactionServer.startShortTimeout_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) |
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.startShort_result(TTransaction success) |
TTransactionServer.startShortTimeout_result(TTransaction success) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.