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

Packages that use ConsumerConfig

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.
co.cask.cdap.data2.transaction.queue.inmemory	This package contains in memory implementation of queues.
co.cask.cdap.data2.transaction.queue.leveldb	This package contains levelDB implementation of queues.
co.cask.cdap.data2.transaction.stream	This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.
co.cask.cdap.data2.transaction.stream.hbase	This package contains class for stream consumer implementation that uses HBase as state store.
co.cask.cdap.data2.transaction.stream.inmemory
co.cask.cdap.data2.transaction.stream.leveldb	This package contains class for stream consumer implementation that uses LevelDB as state store.

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

Methods in co.cask.cdap.data2.queue that return ConsumerConfig

Modifier and Type	Method and Description
ConsumerConfig	QueueConsumer.getConfig() Returns the configuration of this consumer.
ConsumerConfig	ForwardingQueueConsumer.getConfig()

Methods in co.cask.cdap.data2.queue with parameters of type ConsumerConfig

Modifier and Type	Method and Description
QueueConsumer	QueueClientFactory.createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)

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

Methods in co.cask.cdap.data2.transaction.queue that return ConsumerConfig

Modifier and Type	Method and Description
ConsumerConfig	AbstractQueueConsumer.getConfig()

Methods in co.cask.cdap.data2.transaction.queue with parameters of type ConsumerConfig

Modifier and Type	Method and Description
static QueueEntryRow.CanConsume	QueueEntryRow.canConsume(ConsumerConfig consumerConfig, co.cask.tephra.Transaction transaction, long enqueueWritePointer, int counter, byte[] metaValue, byte[] stateValue) Looks at specific queue entry and determines if consumer with given consumer config and current transaction can consume this entry.

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

Constructor and Description
AbstractQueueConsumer(CConfiguration cConf, ConsumerConfig consumerConfig, QueueName queueName)
AbstractQueueConsumer(CConfiguration cConf, ConsumerConfig consumerConfig, QueueName queueName, byte[] startRow)

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

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

Modifier and Type	Method and Description
ConsumerConfig	HBaseConsumerState.getConsumerConfig()
static ConsumerConfig	DequeueScanAttributes.getConsumerConfig(org.apache.hadoop.hbase.client.Scan scan)
static ConsumerConfig	DequeueScanAttributes.readConsumerConfig(DataInput dataInput)

Methods in co.cask.cdap.data2.transaction.queue.hbase with parameters of type ConsumerConfig

Modifier and Type	Method and Description
static Map<String,byte[]>	DequeueScanAttributes.addAttribute(ConsumerConfig consumerConfig, Map<String,byte[]> attributes)
QueueConsumer	HBaseQueueClientFactory.createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)
QueueScanner	SaltedHBaseQueueStrategy.createScanner(ConsumerConfig consumerConfig, org.apache.hadoop.hbase.client.HTable hTable, org.apache.hadoop.hbase.client.Scan scan, int numRows)
QueueScanner	ShardedHBaseQueueStrategy.createScanner(ConsumerConfig consumerConfig, org.apache.hadoop.hbase.client.HTable hTable, org.apache.hadoop.hbase.client.Scan scan, int numRows)
QueueScanner	HBaseQueueStrategy.createScanner(ConsumerConfig consumerConfig, org.apache.hadoop.hbase.client.HTable hTable, org.apache.hadoop.hbase.client.Scan scan, int numRows) Creates a QueueScanner from the given Scan on the HBase table.
byte[]	SaltedHBaseQueueStrategy.getActualRowKey(ConsumerConfig consumerConfig, byte[] originalRowKey)
byte[]	ShardedHBaseQueueStrategy.getActualRowKey(ConsumerConfig consumerConfig, byte[] originalRowKey)
byte[]	HBaseQueueStrategy.getActualRowKey(ConsumerConfig consumerConfig, byte[] originalRowKey) Creates the actual row key used for accessing the HBase table from the given queue entry row key.
static void	DequeueScanAttributes.write(DataOutput dataOutput, ConsumerConfig consumerConfig)

Uses of ConsumerConfig in co.cask.cdap.data2.transaction.queue.inmemory

Methods in co.cask.cdap.data2.transaction.queue.inmemory that return ConsumerConfig

Modifier and Type	Method and Description
ConsumerConfig	InMemoryQueueConsumer.getConfig()

Methods in co.cask.cdap.data2.transaction.queue.inmemory with parameters of type ConsumerConfig

Modifier and Type	Method and Description
void	InMemoryQueue.ack(List<InMemoryQueue.Key> dequeuedKeys, ConsumerConfig config)
QueueConsumer	InMemoryQueueClientFactory.createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)
ImmutablePair<List<InMemoryQueue.Key>,List<byte[]>>	InMemoryQueue.dequeue(co.cask.tephra.Transaction tx, ConsumerConfig config, InMemoryQueue.ConsumerState consumerState, int maxBatchSize)
void	InMemoryQueue.undoDequeue(List<InMemoryQueue.Key> dequeuedKeys, ConsumerConfig config)

Constructors in co.cask.cdap.data2.transaction.queue.inmemory with parameters of type ConsumerConfig

Constructor and Description
InMemoryQueueConsumer(QueueName queueName, ConsumerConfig config, int numGroups, InMemoryQueueService queueService)

Uses of ConsumerConfig in co.cask.cdap.data2.transaction.queue.leveldb

Methods in co.cask.cdap.data2.transaction.queue.leveldb with parameters of type ConsumerConfig

Modifier and Type	Method and Description
QueueConsumer	LevelDBQueueClientFactory.createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)
QueueConsumer	LevelDBAndInMemoryQueueClientFactory.createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)

Uses of ConsumerConfig in co.cask.cdap.data2.transaction.stream

Methods in co.cask.cdap.data2.transaction.stream that return ConsumerConfig

Modifier and Type	Method and Description
ConsumerConfig	StreamConsumer.getConsumerConfig()
ConsumerConfig	ForwardingStreamConsumer.getConsumerConfig()
ConsumerConfig	QueueToStreamConsumer.getConsumerConfig()
ConsumerConfig	AbstractStreamFileConsumer.getConsumerConfig()

Methods in co.cask.cdap.data2.transaction.stream with parameters of type ConsumerConfig

Modifier and Type	Method and Description
StreamConsumer	StreamConsumerFactory.create(Id.Stream streamId, String namespace, ConsumerConfig consumerConfig) Creates a StreamConsumer.
StreamConsumer	AbstractStreamFileConsumerFactory.create(Id.Stream streamId, String namespace, ConsumerConfig consumerConfig)
protected abstract StreamConsumer	AbstractStreamFileConsumerFactory.create(TableId tableId, StreamConfig streamConfig, ConsumerConfig consumerConfig, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, ReadFilter extraFilter) Creates a StreamConsumer.

Constructors in co.cask.cdap.data2.transaction.stream with parameters of type ConsumerConfig

Constructor and Description
AbstractStreamFileConsumer(CConfiguration cConf, StreamConfig streamConfig, ConsumerConfig consumerConfig, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, StreamConsumerStateStore consumerStateStore, StreamConsumerState beginConsumerState, ReadFilter extraFilter)
QueueToStreamConsumer(Id.Stream streamId, ConsumerConfig consumerConfig, QueueConsumer consumer)

Uses of ConsumerConfig in co.cask.cdap.data2.transaction.stream.hbase

Methods in co.cask.cdap.data2.transaction.stream.hbase with parameters of type ConsumerConfig

Modifier and Type	Method and Description
protected StreamConsumer	HBaseStreamFileConsumerFactory.create(TableId tableId, StreamConfig streamConfig, ConsumerConfig consumerConfig, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, ReadFilter extraFilter)

Constructors in co.cask.cdap.data2.transaction.stream.hbase with parameters of type ConsumerConfig

Constructor and Description
HBaseStreamFileConsumer(CConfiguration cConf, StreamConfig streamConfig, ConsumerConfig consumerConfig, HBaseTableUtil tableUtil, org.apache.hadoop.hbase.client.HTable hTable, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, ReadFilter extraFilter, AbstractRowKeyDistributor keyDistributor) Constructor.

Uses of ConsumerConfig in co.cask.cdap.data2.transaction.stream.inmemory

Methods in co.cask.cdap.data2.transaction.stream.inmemory with parameters of type ConsumerConfig

Modifier and Type	Method and Description
StreamConsumer	InMemoryStreamConsumerFactory.create(Id.Stream streamId, String namespace, ConsumerConfig consumerConfig)

Uses of ConsumerConfig in co.cask.cdap.data2.transaction.stream.leveldb

Methods in co.cask.cdap.data2.transaction.stream.leveldb with parameters of type ConsumerConfig

Modifier and Type	Method and Description
protected StreamConsumer	LevelDBStreamFileConsumerFactory.create(TableId tableId, StreamConfig streamConfig, ConsumerConfig consumerConfig, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, ReadFilter extraFilter)

Constructors in co.cask.cdap.data2.transaction.stream.leveldb with parameters of type ConsumerConfig

Constructor and Description
LevelDBStreamFileConsumer(CConfiguration cConf, StreamConfig streamConfig, ConsumerConfig consumerConfig, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, ReadFilter extraFilter, LevelDBTableCore tableCore, Object dbLock)