co.cask.cdap.data2.transaction.coprocessor

Class DefaultTransactionStateCache

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

co.cask.tephra.coprocessor.TransactionStateCache

co.cask.cdap.data2.transaction.coprocessor.DefaultTransactionStateCache

All Implemented Interfaces:

com.google.common.util.concurrent.Service, Configurable

public class DefaultTransactionStateCache
extends co.cask.tephra.coprocessor.TransactionStateCache

Extends the TransactionStateCache implementation for transaction coprocessors with a version that reads transaction configuration properties from ConfigurationTable. This allows the coprocessors to pick up configuration changes without requiring a restart.

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
DefaultTransactionStateCache(String sysConfigTablePrefix)

Method Summary

Methods

Modifier and Type	Method and Description
protected Configuration	getSnapshotConfiguration()
void	setConf(Configuration conf)

Methods inherited from class co.cask.tephra.coprocessor.TransactionStateCache

getConf, getLatestState, shutDown, startUp

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

addListener, executor, isRunning, 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

DefaultTransactionStateCache

public DefaultTransactionStateCache(String sysConfigTablePrefix)

Method Detail

setConf

public void setConf(Configuration conf)

Specified by:

setConf in interface Configurable

Overrides:

setConf in class co.cask.tephra.coprocessor.TransactionStateCache

getSnapshotConfiguration

protected Configuration getSnapshotConfiguration()
                                          throws IOException

Overrides:

getSnapshotConfiguration in class co.cask.tephra.coprocessor.TransactionStateCache

Throws:

IOException