co.cask.cdap.data2.transaction.coprocessor

Class DefaultTransactionStateCacheSupplier

java.lang.Object

co.cask.tephra.coprocessor.TransactionStateCacheSupplier

co.cask.cdap.data2.transaction.coprocessor.DefaultTransactionStateCacheSupplier

All Implemented Interfaces:

com.google.common.base.Supplier<co.cask.tephra.coprocessor.TransactionStateCache>

public class DefaultTransactionStateCacheSupplier
extends co.cask.tephra.coprocessor.TransactionStateCacheSupplier

Provides a single shared instance of DefaultTransactionStateCache for use by transaction coprocessors.

Field Summary

Fields inherited from class co.cask.tephra.coprocessor.TransactionStateCacheSupplier

conf, instance, lock

Constructor Summary

Constructors

Constructor and Description
DefaultTransactionStateCacheSupplier(String sysConfigTablePrefix, Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.tephra.coprocessor.TransactionStateCache	get() Returns a singleton instance of the transaction state cache, performing lazy initialization if necessary.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTransactionStateCacheSupplier

public DefaultTransactionStateCacheSupplier(String sysConfigTablePrefix,
                                    Configuration conf)

Method Detail

get

public co.cask.tephra.coprocessor.TransactionStateCache get()

Returns a singleton instance of the transaction state cache, performing lazy initialization if necessary.

Specified by:

get in interface com.google.common.base.Supplier<co.cask.tephra.coprocessor.TransactionStateCache>

Overrides:

get in class co.cask.tephra.coprocessor.TransactionStateCacheSupplier

Returns:

A shared instance of the transaction state cache.