Uses of Interface
co.cask.cdap.data2.transaction.stream.StreamConsumer

Packages that use StreamConsumer

Package	Description
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 StreamConsumer in co.cask.cdap.data2.transaction.stream

Classes in co.cask.cdap.data2.transaction.stream that implement StreamConsumer

Modifier and Type	Class and Description
class	AbstractStreamFileConsumer A StreamConsumer that read events from stream file and uses a table to store consumer states.
class	ForwardingStreamConsumer A StreamConsumer that forwards every methods to another StreamConsumer.
class	QueueToStreamConsumer An adapter from Queue2Consumer to StreamConsumer.

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

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 StreamConsumer

Constructor and Description
ForwardingStreamConsumer(StreamConsumer delegate)

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

Classes in co.cask.cdap.data2.transaction.stream.hbase that implement StreamConsumer

Modifier and Type	Class and Description
class	HBaseStreamFileConsumer A StreamConsumer that uses HTable to store consuming states.

Methods in co.cask.cdap.data2.transaction.stream.hbase that return StreamConsumer

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)

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

Methods in co.cask.cdap.data2.transaction.stream.inmemory that return StreamConsumer

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

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

Classes in co.cask.cdap.data2.transaction.stream.leveldb that implement StreamConsumer

Modifier and Type	Class and Description
class	LevelDBStreamFileConsumer

Methods in co.cask.cdap.data2.transaction.stream.leveldb that return StreamConsumer

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)