co.cask.cdap.data2.transaction.queue

Interface QueueConfigurer

All Superinterfaces:

AutoCloseable, Closeable, co.cask.tephra.TransactionAware

All Known Implementing Classes:

HBaseConsumerStateStore, NoopQueueConfigurer

public interface QueueConfigurer
extends co.cask.tephra.TransactionAware, Closeable

Provides methods to configure queue. Configuration needs to happen inside a transaction.

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.

Methods inherited from interface co.cask.tephra.TransactionAware

commitTx, getTransactionAwareName, getTxChanges, postTxCommit, rollbackTx, startTx, updateTx

Methods inherited from interface java.io.Closeable

close

Method Detail

configureInstances

void configureInstances(long groupId,
                      int instances)
                        throws Exception

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

Parameters:

groupId - groupId of the consumer group

instances - number of instances to change to

Throws:

Exception - if failed to change number of instances.

configureGroups

void configureGroups(Iterable<? extends ConsumerGroupConfig> groupConfigs)
                     throws Exception

Changes the configuration of all consumer groups.

Parameters:

groupConfigs - information for all consumer groups

Throws:

Exception - if failed to change consumer group configuration