| 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.