co.cask.cdap.data2.dataset2.tx

Class TransactionalDatasetRegistry<CONTEXT_TYPE extends TxContext>

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

co.cask.cdap.common.service.UncaughtExceptionIdleService

co.cask.cdap.data2.dataset2.tx.TransactionalDatasetRegistry<CONTEXT_TYPE>

Type Parameters:

CONTEXT_TYPE - type of the tx operation context

All Implemented Interfaces:

com.google.common.util.concurrent.Service

Direct Known Subclasses:

MDSDatasetsRegistry

public abstract class TransactionalDatasetRegistry<CONTEXT_TYPE extends TxContext>
extends UncaughtExceptionIdleService

Utility that wraps the execution of a function into the context of a transaction. TODO: unify with TransactionExecutor as per comment in https://github.co.cask.cdap/reactor/pull/1243

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
TransactionalDatasetRegistry(TransactionSystemClientService txClient)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract CONTEXT_TYPE	createContext()
<RETURN_TYPE> RETURN_TYPE	execute(TxCallable<CONTEXT_TYPE,RETURN_TYPE> tx)
<RETURN_TYPE> RETURN_TYPE	executeUnchecked(TxCallable<CONTEXT_TYPE,RETURN_TYPE> tx)
protected org.slf4j.Logger	getUncaughtExceptionLogger()
protected void	startUp()

Methods inherited from class co.cask.cdap.common.service.UncaughtExceptionIdleService

executor, newHandler

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, isRunning, shutDown, start, startAndWait, state, stop, stopAndWait, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionalDatasetRegistry

public TransactionalDatasetRegistry(TransactionSystemClientService txClient)

Method Detail

startUp

protected void startUp()
                throws Exception

Specified by:

startUp in class com.google.common.util.concurrent.AbstractIdleService

Throws:

Exception

execute

public <RETURN_TYPE> RETURN_TYPE execute(TxCallable<CONTEXT_TYPE,RETURN_TYPE> tx)
                    throws co.cask.tephra.TransactionFailureException,
                           IOException,
                           DatasetManagementException,
                           InterruptedException

Throws:

co.cask.tephra.TransactionFailureException

IOException

DatasetManagementException

InterruptedException

executeUnchecked

public <RETURN_TYPE> RETURN_TYPE executeUnchecked(TxCallable<CONTEXT_TYPE,RETURN_TYPE> tx)

createContext

protected abstract CONTEXT_TYPE createContext()
                                                         throws IOException,
                                                                DatasetManagementException

Throws:

IOException

DatasetManagementException

getUncaughtExceptionLogger

protected org.slf4j.Logger getUncaughtExceptionLogger()

Specified by:

getUncaughtExceptionLogger in class UncaughtExceptionIdleService