co.cask.cdap.data2.transaction

Class DynamicTransactionExecutor

java.lang.Object

co.cask.tephra.AbstractTransactionExecutor

co.cask.cdap.data2.transaction.DynamicTransactionExecutor

All Implemented Interfaces:

co.cask.tephra.TransactionExecutor

public class DynamicTransactionExecutor
extends co.cask.tephra.AbstractTransactionExecutor

Utility class that encapsulates the transaction life cycle over a given set of transaction-aware datasets. The executor can be reused across multiple invocations of the execute() method. However, it is not thread-safe for concurrent execution.

Transaction execution will be retries according to specified in constructor RetryStrategy. By default RetryOnConflictStrategy is used with max 20 retries and 100 ms between retries.

This is a copy of Tephra's transaction executor, with the difference that it creates transaction contexts using a supplier, instead of ceating it directly from a list of transaction-aware's. This alow using it with a DynamicDatasetCache, where the set of datasets participating in transactions can change while the transaction is executed. TODO: (CDAP-3988) remove this once TEPHRA-137 is done.

Nested Class Summary

Nested classes/interfaces inherited from interface co.cask.tephra.TransactionExecutor

co.cask.tephra.TransactionExecutor.Function<I,O>, co.cask.tephra.TransactionExecutor.Procedure<I>, co.cask.tephra.TransactionExecutor.Subroutine

Constructor Summary

Constructors

Constructor and Description
DynamicTransactionExecutor(com.google.common.base.Supplier<co.cask.tephra.TransactionContext> txContextSupplier)
DynamicTransactionExecutor(com.google.common.base.Supplier<co.cask.tephra.TransactionContext> txContextSupplier, co.cask.tephra.RetryStrategy retryStrategy)

Method Summary

Methods

Modifier and Type	Method and Description
<O> O	execute(Callable<O> callable)
<I,O> O	execute(co.cask.tephra.TransactionExecutor.Function<I,O> function, I input)
<I> void	execute(co.cask.tephra.TransactionExecutor.Procedure<I> procedure, I input)
void	execute(co.cask.tephra.TransactionExecutor.Subroutine subroutine)

Methods inherited from class co.cask.tephra.AbstractTransactionExecutor

executeUnchecked, executeUnchecked, executeUnchecked, executeUnchecked, submit, submit, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamicTransactionExecutor

public DynamicTransactionExecutor(com.google.common.base.Supplier<co.cask.tephra.TransactionContext> txContextSupplier,
                          co.cask.tephra.RetryStrategy retryStrategy)

DynamicTransactionExecutor

public DynamicTransactionExecutor(com.google.common.base.Supplier<co.cask.tephra.TransactionContext> txContextSupplier)

Method Detail

execute

public <I,O> O execute(co.cask.tephra.TransactionExecutor.Function<I,O> function,
              I input)
          throws co.cask.tephra.TransactionFailureException,
                 InterruptedException

Throws:

co.cask.tephra.TransactionFailureException

InterruptedException

execute

public <I> void execute(co.cask.tephra.TransactionExecutor.Procedure<I> procedure,
               I input)
             throws co.cask.tephra.TransactionFailureException,
                    InterruptedException

Throws:

co.cask.tephra.TransactionFailureException

InterruptedException

execute

public <O> O execute(Callable<O> callable)
          throws co.cask.tephra.TransactionFailureException,
                 InterruptedException

Throws:

co.cask.tephra.TransactionFailureException

InterruptedException

execute

public void execute(co.cask.tephra.TransactionExecutor.Subroutine subroutine)
             throws co.cask.tephra.TransactionFailureException,
                    InterruptedException

Throws:

co.cask.tephra.TransactionFailureException

InterruptedException