co.cask.cdap.data2.transaction.queue.hbase.coprocessor

Class ConsumerConfigCache

java.lang.Object

co.cask.cdap.data2.transaction.queue.hbase.coprocessor.ConsumerConfigCache

public class ConsumerConfigCache
extends Object

Provides a RegionServer shared cache for all instances of HBaseQueueRegionObserver of the recent queue consumer configuration.

Method Summary

Methods

Modifier and Type	Method and Description
QueueConsumerConfig	getConsumerConfig(byte[] queueName)
static ConsumerConfigCache	getInstance(org.apache.hadoop.hbase.TableName tableName, CConfigurationReader cConfReader, com.google.common.base.Supplier<co.cask.tephra.persist.TransactionVisibilityState> txSnapshotSupplier, com.google.common.io.InputSupplier<org.apache.hadoop.hbase.client.HTableInterface> hTableSupplier)
boolean	isAlive()
void	updateCache() This forces an immediate update of the config cache.

Methods inherited from class java.lang.Object

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

Method Detail

isAlive

public boolean isAlive()

getConsumerConfig

@Nullable
public QueueConsumerConfig getConsumerConfig(byte[] queueName)

updateCache

public void updateCache()
                 throws IOException

This forces an immediate update of the config cache. It should only be called from the refresh thread or from tests, to avoid having to add a sleep for the duration of the refresh interval. This method is synchronized to protect from race conditions if called directly from a test. Otherwise this is only called from the refresh thread, and there will not be concurrent invocations.

Throws:

IOException - if failed to update config cache

getInstance

public static ConsumerConfigCache getInstance(org.apache.hadoop.hbase.TableName tableName,
                              CConfigurationReader cConfReader,
                              com.google.common.base.Supplier<co.cask.tephra.persist.TransactionVisibilityState> txSnapshotSupplier,
                              com.google.common.io.InputSupplier<org.apache.hadoop.hbase.client.HTableInterface> hTableSupplier)