Package | Description |
---|---|
org.apache.tephra |
This package contains implementations of the transaction system v2.
|
org.apache.tephra.visibility |
Modifier and Type | Class and Description |
---|---|
class |
TransactionConflictException
Thrown to indicate transaction conflict occurred when trying to commit a transaction.
|
class |
TransactionNotInProgressException
Thrown when transaction has timed out.
|
Modifier and Type | Method and Description |
---|---|
void |
TransactionContext.abort(TransactionFailureException cause)
Aborts the given transaction, and rolls back all data set changes.
|
long |
RetryStrategy.nextRetry(TransactionFailureException reason,
int failureCount)
Returns the number of milliseconds to wait before retrying the operation.
|
long |
RetryOnConflictStrategy.nextRetry(TransactionFailureException reason,
int failureCount) |
long |
NoRetryStrategy.nextRetry(TransactionFailureException reason,
int failureCount) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionContext.abort()
Aborts the given transaction, and rolls back all data set changes.
|
void |
TransactionContext.abort(TransactionFailureException cause)
Aborts the given transaction, and rolls back all data set changes.
|
void |
TransactionContext.checkpoint()
Checkpoints the current transaction by flushing any pending writes for the registered
TransactionAware
instances, and obtaining a new current write pointer for the transaction. |
<O> O |
TransactionExecutor.execute(Callable<O> callable)
Like
TransactionExecutor.execute(Function, Object) but the callable has no argument. |
<O> O |
DefaultTransactionExecutor.execute(Callable<O> callable) |
<I,O> O |
TransactionExecutor.execute(TransactionExecutor.Function<I,O> function,
I input)
Execute a function under transactional semantics.
|
<I,O> O |
DefaultTransactionExecutor.execute(TransactionExecutor.Function<I,O> function,
I input) |
<I> void |
TransactionExecutor.execute(TransactionExecutor.Procedure<I> procedure,
I input)
Like
TransactionExecutor.execute(Function, Object) but without a return value. |
<I> void |
DefaultTransactionExecutor.execute(TransactionExecutor.Procedure<I> procedure,
I input) |
void |
TransactionExecutor.execute(TransactionExecutor.Subroutine subroutine)
Like
TransactionExecutor.execute(Function, Object) but without argument or return value. |
void |
DefaultTransactionExecutor.execute(TransactionExecutor.Subroutine subroutine) |
void |
TransactionContext.finish()
Commits the current transaction.
|
void |
TransactionContext.start()
Starts a new transaction.
|
Modifier and Type | Method and Description |
---|---|
void |
FenceWait.await(long timeout,
TimeUnit timeUnit)
Waits until the fence is complete, or till the timeout specified.
|
void |
DefaultFenceWait.await(long timeout,
TimeUnit timeUnit) |
static FenceWait |
VisibilityFence.prepareWait(byte[] fenceId,
TransactionSystemClient txClient)
Used by a writer to wait on a fence so that changes are visible to all readers with in-progress transactions.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.