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

Packages that use StreamConsumerFactory

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

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

Modifier and Type	Class and Description
class	AbstractStreamFileConsumerFactory Abstract base class for implementing StreamConsumerFactory using MultiLiveStreamFileReader.

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

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

Modifier and Type	Class and Description
class	HBaseStreamFileConsumerFactory A StreamConsumerFactory that reads from stream file and uses HBase as the store for consumer process states.

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

Classes in co.cask.cdap.data2.transaction.stream.inmemory that implement StreamConsumerFactory

Modifier and Type	Class and Description
class	InMemoryStreamConsumerFactory In memory implementation of StreamConsumer would be using the in memory queue implementation.

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

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

Modifier and Type	Class and Description
class	LevelDBStreamFileConsumerFactory A StreamConsumerFactory that reads from stream file and uses LevelDB as the store for consumer process states.