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

Class HBaseConsumerStateStore

java.lang.Object

co.cask.cdap.api.dataset.lib.AbstractDataset

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

All Implemented Interfaces:

co.cask.cdap.api.dataset.Dataset, co.cask.cdap.api.dataset.metrics.MeteredDataset, QueueConfigurer, co.cask.tephra.TransactionAware, Closeable, AutoCloseable

public final class HBaseConsumerStateStore
extends co.cask.cdap.api.dataset.lib.AbstractDataset
implements QueueConfigurer

Class for persisting consumer state per queue consumer.

Method Summary

Methods

Modifier and Type	Method and Description
void	configureGroups(Iterable<? extends ConsumerGroupConfig> groupConfigs) Changes the configuration of all consumer groups.
void	configureInstances(long groupId, int instances) Changes the number of consumer instances of the given consumer group.
com.google.common.collect.Multimap<Long,QueueBarrier>	getAllBarriers() Gets all barrier information for all groups.
List<QueueBarrier>	getAllBarriers(long groupId) Gets all barrier information for the given group.
co.cask.tephra.Transaction	getTransaction()
void	startTx(co.cask.tephra.Transaction tx)

Methods inherited from class co.cask.cdap.api.dataset.lib.AbstractDataset

close, commitTx, getName, getTransactionAwareName, getTxChanges, postTxCommit, rollbackTx, setMetricsCollector, toString, updateTx

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.tephra.TransactionAware

commitTx, getTransactionAwareName, getTxChanges, postTxCommit, rollbackTx, updateTx

Methods inherited from interface java.io.Closeable

close

Method Detail

startTx

public void startTx(co.cask.tephra.Transaction tx)

Specified by:

startTx in interface co.cask.tephra.TransactionAware

Overrides:

startTx in class co.cask.cdap.api.dataset.lib.AbstractDataset

configureInstances

public void configureInstances(long groupId,
                      int instances)

Description copied from interface: QueueConfigurer

Changes the number of consumer instances of the given consumer group. The consumer group configuration needs to be existed already.

Specified by:

configureInstances in interface QueueConfigurer

Parameters:

groupId - groupId of the consumer group

instances - number of instances to change to

configureGroups

public void configureGroups(Iterable<? extends ConsumerGroupConfig> groupConfigs)

Description copied from interface: QueueConfigurer

Changes the configuration of all consumer groups.

Specified by:

configureGroups in interface QueueConfigurer

Parameters:

groupConfigs - information for all consumer groups

getTransaction

public co.cask.tephra.Transaction getTransaction()

getAllBarriers

public List<QueueBarrier> getAllBarriers(long groupId)

Gets all barrier information for the given group. The information are sorted in the order of the barrier changes.

getAllBarriers

public com.google.common.collect.Multimap<Long,QueueBarrier> getAllBarriers()

Gets all barrier information for all groups. The information are sorted in the order of the barrier changes.