Uses of Class
co.cask.cdap.data2.queue.ConsumerGroupConfig

Packages that use ConsumerGroupConfig

Package	Description
co.cask.cdap.data2.queue	API definition for queue for the txds2 system.
co.cask.cdap.data2.transaction.queue	Transaction aware queue implementation.
co.cask.cdap.data2.transaction.queue.hbase	This package contains an HBase implementation of queues.

Uses of ConsumerGroupConfig in co.cask.cdap.data2.queue

Subclasses of ConsumerGroupConfig in co.cask.cdap.data2.queue

Modifier and Type	Class and Description
class	ConsumerConfig Contains queue consumer instance configuration.

Constructors in co.cask.cdap.data2.queue with parameters of type ConsumerGroupConfig

Constructor and Description
ConsumerConfig(ConsumerGroupConfig groupConfig, int instanceId)
ConsumerGroupConfig(ConsumerGroupConfig other)

Uses of ConsumerGroupConfig in co.cask.cdap.data2.transaction.queue

Method parameters in co.cask.cdap.data2.transaction.queue with type arguments of type ConsumerGroupConfig

Modifier and Type	Method and Description
void	NoopQueueConfigurer.configureGroups(Iterable<? extends ConsumerGroupConfig> groupConfigs)
void	QueueConfigurer.configureGroups(Iterable<? extends ConsumerGroupConfig> groupConfigs) Changes the configuration of all consumer groups.

Uses of ConsumerGroupConfig in co.cask.cdap.data2.transaction.queue.hbase

Methods in co.cask.cdap.data2.transaction.queue.hbase that return ConsumerGroupConfig

Modifier and Type	Method and Description
ConsumerGroupConfig	QueueBarrier.getGroupConfig()

Method parameters in co.cask.cdap.data2.transaction.queue.hbase with type arguments of type ConsumerGroupConfig

Modifier and Type	Method and Description
void	HBaseConsumerStateStore.configureGroups(Iterable<? extends ConsumerGroupConfig> groupConfigs)
void	SaltedHBaseQueueStrategy.getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs, QueueEntry queueEntry, byte[] rowKeyPrefix, long writePointer, int counter, Collection<byte[]> rowKeys)
void	ShardedHBaseQueueStrategy.getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs, QueueEntry queueEntry, byte[] rowKeyPrefix, long writePointer, int counter, Collection<byte[]> rowKeys)
void	HBaseQueueStrategy.getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs, QueueEntry queueEntry, byte[] rowKeyPrefix, long writePointer, int counter, Collection<byte[]> rowKeys) Get all the row keys that the queue entries need to write to.

Constructor parameters in co.cask.cdap.data2.transaction.queue.hbase with type arguments of type ConsumerGroupConfig

Constructor and Description
HBaseQueueProducer(org.apache.hadoop.hbase.client.HTable hTable, QueueName queueName, QueueMetrics queueMetrics, HBaseQueueStrategy queueStrategy, Iterable<? extends ConsumerGroupConfig> consumerGroupConfigs)