co.cask.cdap.data2.transaction

Class Transactions

java.lang.Object

co.cask.cdap.data2.transaction.Transactions

public final class Transactions
extends Object

Helper class for interacting with Transaction and TransactionSystemClient.

Method Summary

Methods

Modifier and Type	Method and Description
static void	abortQuietly(co.cask.tephra.TransactionSystemClient txClient, co.cask.tephra.Transaction tx)
static com.google.common.base.Supplier<co.cask.tephra.TransactionContext>	constantContextSupplier(co.cask.tephra.TransactionSystemClient txClient, Iterable<? extends co.cask.tephra.TransactionAware> txAwares)
static com.google.common.base.Supplier<co.cask.tephra.TransactionContext>	constantContextSupplier(co.cask.tephra.TransactionSystemClient txClient, co.cask.tephra.TransactionAware txAware)
static co.cask.tephra.TransactionExecutor	createTransactionExecutor(co.cask.tephra.TransactionExecutorFactory factory, Iterable<? extends co.cask.tephra.TransactionAware> txAwares) Handy method to create TransactionExecutor (See TEPHRA-71).
static co.cask.tephra.TransactionExecutor	createTransactionExecutor(co.cask.tephra.TransactionExecutorFactory factory, co.cask.tephra.TransactionAware txAware)
static co.cask.tephra.TransactionExecutor	createTransactionExecutor(TransactionExecutorFactory factory, co.cask.tephra.TransactionSystemClient txClient, Iterable<? extends co.cask.tephra.TransactionAware> txAwares) Handy method to create TransactionExecutor (See TEPHRA-71).
static co.cask.tephra.TransactionExecutor	createTransactionExecutor(TransactionExecutorFactory factory, co.cask.tephra.TransactionSystemClient txClient, co.cask.tephra.TransactionAware txAware) Handy method to create TransactionExecutor with single TransactionAware.
static <V> V	execute(co.cask.tephra.TransactionContext txContext, String name, Callable<V> callable) Executes the given Callable in a short transaction using the given TransactionContext.
static void	execute(co.cask.tephra.TransactionContext txContext, String name, Runnable runnable) Executes the given Runnable in a short transaction using the given TransactionContext.
static void	invalidateQuietly(co.cask.tephra.TransactionSystemClient txClient, co.cask.tephra.Transaction tx)

Methods inherited from class java.lang.Object

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

Method Detail

abortQuietly

public static void abortQuietly(co.cask.tephra.TransactionSystemClient txClient,
                co.cask.tephra.Transaction tx)

invalidateQuietly

public static void invalidateQuietly(co.cask.tephra.TransactionSystemClient txClient,
                     co.cask.tephra.Transaction tx)

constantContextSupplier

public static com.google.common.base.Supplier<co.cask.tephra.TransactionContext> constantContextSupplier(co.cask.tephra.TransactionSystemClient txClient,
                                                                                         co.cask.tephra.TransactionAware txAware)

constantContextSupplier

public static com.google.common.base.Supplier<co.cask.tephra.TransactionContext> constantContextSupplier(co.cask.tephra.TransactionSystemClient txClient,
                                                                                         Iterable<? extends co.cask.tephra.TransactionAware> txAwares)

createTransactionExecutor

public static co.cask.tephra.TransactionExecutor createTransactionExecutor(TransactionExecutorFactory factory,
                                                           co.cask.tephra.TransactionSystemClient txClient,
                                                           Iterable<? extends co.cask.tephra.TransactionAware> txAwares)

Handy method to create TransactionExecutor (See TEPHRA-71).

createTransactionExecutor

public static co.cask.tephra.TransactionExecutor createTransactionExecutor(TransactionExecutorFactory factory,
                                                           co.cask.tephra.TransactionSystemClient txClient,
                                                           co.cask.tephra.TransactionAware txAware)

Handy method to create TransactionExecutor with single TransactionAware.

createTransactionExecutor

public static co.cask.tephra.TransactionExecutor createTransactionExecutor(co.cask.tephra.TransactionExecutorFactory factory,
                                                           Iterable<? extends co.cask.tephra.TransactionAware> txAwares)

Handy method to create TransactionExecutor (See TEPHRA-71).

createTransactionExecutor

public static co.cask.tephra.TransactionExecutor createTransactionExecutor(co.cask.tephra.TransactionExecutorFactory factory,
                                                           co.cask.tephra.TransactionAware txAware)

execute

public static void execute(co.cask.tephra.TransactionContext txContext,
           String name,
           Runnable runnable)
                    throws co.cask.tephra.TransactionFailureException

Executes the given Runnable in a short transaction using the given TransactionContext.

Parameters:

txContext - the TransactionContext for managing the transaction lifecycle

name - descriptive name for the runnable

runnable - the Runnable to be executed inside a transaction

Throws:

co.cask.tephra.TransactionFailureException - if failed to execute in a transaction. The cause of the exception carries the reason of failure.

execute

public static <V> V execute(co.cask.tephra.TransactionContext txContext,
            String name,
            Callable<V> callable)
                 throws co.cask.tephra.TransactionFailureException

Executes the given Callable in a short transaction using the given TransactionContext.

Parameters:

txContext - the TransactionContext for managing the transaction lifecycle

name - descriptive name for the runnable

callable - the Callable to be executed inside a transaction

Returns:

the result returned by Callable.call()

Throws:

co.cask.tephra.TransactionFailureException - if failed to execute in a transaction. The cause of the exception carries the reason of failure.