co.cask.cdap.data2.dataset2.tx

Class Transactional<T extends Iterable<V>,V>

java.lang.Object

co.cask.cdap.data2.dataset2.tx.Transactional<T,V>

Type Parameters:

T - type of the transactional context

V - type of objects contained inside the transaction context

Deprecated.

Don't use this class anymore. Use TransactionExecutor instead.

@Deprecated
public class Transactional<T extends Iterable<V>,V>
extends Object

Handy utility for performing transactional operations that delegates execution to TransactionExecutor and manages resources in transaction context. Transaction context is supplied using given Supplier and provides list of resources by implementing Iterable. This applies transaction logic to those resources that implement TransactionAware. Additionally, if resource implements Closeable its Closeable.close() is invoked at the end of transaction.

Method Summary

Methods

Modifier and Type	Method and Description
<R> R	execute(co.cask.tephra.TransactionExecutor.Function<T,R> func) Deprecated. Executes given function within new transaction.
static <V,T extends Iterable<V>,R> R	execute(co.cask.tephra.TransactionExecutorFactory txFactory, com.google.common.base.Supplier<T> supplier, co.cask.tephra.TransactionExecutor.Function<T,R> func) Deprecated. Executes function within new transaction.
<R> R	executeUnchecked(co.cask.tephra.TransactionExecutor.Function<T,R> func) Deprecated. Executes given function within new transaction and rethrows all exceptions with Throwables.propagate(Throwable)
static <T extends Iterable<V>,V> Transactional<T,V>	of(co.cask.tephra.TransactionExecutorFactory txFactory, com.google.common.base.Supplier<T> supplier) Deprecated.

Methods inherited from class java.lang.Object

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

Method Detail

of

public static <T extends Iterable<V>,V> Transactional<T,V> of(co.cask.tephra.TransactionExecutorFactory txFactory,
                                              com.google.common.base.Supplier<T> supplier)

Deprecated.

execute

public <R> R execute(co.cask.tephra.TransactionExecutor.Function<T,R> func)
          throws co.cask.tephra.TransactionFailureException,
                 InterruptedException,
                 IOException

Deprecated.

Executes given function within new transaction.

Throws:

co.cask.tephra.TransactionFailureException

InterruptedException

IOException

executeUnchecked

public <R> R executeUnchecked(co.cask.tephra.TransactionExecutor.Function<T,R> func)

Deprecated.

Executes given function within new transaction and rethrows all exceptions with Throwables.propagate(Throwable)

execute

public static <V,T extends Iterable<V>,R> R execute(co.cask.tephra.TransactionExecutorFactory txFactory,
                                    com.google.common.base.Supplier<T> supplier,
                                    co.cask.tephra.TransactionExecutor.Function<T,R> func)
                 throws co.cask.tephra.TransactionFailureException,
                        IOException,
                        InterruptedException

Deprecated.

Executes function within new transaction. See Transactional for more details.

Type Parameters:

V - type of object contained inside the transaction context

T - type of the transaction context

R - type of the function result

Parameters:

txFactory - transaction factory to create new transaction

supplier - supplier of transaction context

func - function to execute

Returns:

function result

Throws:

co.cask.tephra.TransactionFailureException

IOException

InterruptedException