Uses of Package
co.cask.cdap.data2.transaction.stream

Packages that use co.cask.cdap.data2.transaction.stream

Package	Description
co.cask.cdap.data.runtime	This package contains implementations and guice-bindings needed for data-fabric runtime.
co.cask.cdap.data.stream	This package contains classes for management and manipulation of stream files.
co.cask.cdap.data.stream.service	This package contains class for running stream http service as well as twill runnable for running the service in YARN.
co.cask.cdap.data.stream.service.upload
co.cask.cdap.data2.metadata.system
co.cask.cdap.data2.transaction.queue.inmemory	This package contains in memory 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.

Classes in co.cask.cdap.data2.transaction.stream used by co.cask.cdap.data.runtime

Class and Description
StreamConfig Represents the configuration of a stream.

Classes in co.cask.cdap.data2.transaction.stream used by co.cask.cdap.data.stream

Class and Description
StreamAdmin
StreamConfig Represents the configuration of a stream.

Classes in co.cask.cdap.data2.transaction.stream used by co.cask.cdap.data.stream.service

Class and Description
StreamAdmin

Classes in co.cask.cdap.data2.transaction.stream used by co.cask.cdap.data.stream.service.upload

Class and Description
StreamConfig Represents the configuration of a stream.

Classes in co.cask.cdap.data2.transaction.stream used by co.cask.cdap.data2.metadata.system

Class and Description
StreamConfig Represents the configuration of a stream.

Classes in co.cask.cdap.data2.transaction.stream used by co.cask.cdap.data2.transaction.queue.inmemory

Class and Description
StreamAdmin
StreamConfig Represents the configuration of a stream.

Classes in co.cask.cdap.data2.transaction.stream used by co.cask.cdap.data2.transaction.stream

Class and Description
AbstractStreamFileConsumer.StateScanner Scanner for scanning state table.
ConsumerState Represents state of a consumer.
ConsumerStateStore Represents storage for ConsumerState.
StreamAdmin
StreamConfig Represents the configuration of a stream.
StreamConfig.Builder A builder to help building instance of StreamConfig.
StreamConsumer Represents a transaction stream consumer.
StreamConsumerFactory Factory for creating StreamConsumer.
StreamConsumerState Represents the consumer state of a StreamConsumer.
StreamConsumerStateStore Represents storage for ConsumerState for stream consumers.
StreamConsumerStateStoreFactory Factory for creating StreamConsumerStateStore instance for different streams.

Classes in co.cask.cdap.data2.transaction.stream used by co.cask.cdap.data2.transaction.stream.hbase

Class and Description
AbstractStreamFileConsumer A StreamConsumer that read events from stream file and uses a table to store consumer states.
AbstractStreamFileConsumer.StateScanner Scanner for scanning state table.
AbstractStreamFileConsumerFactory Abstract base class for implementing StreamConsumerFactory using MultiLiveStreamFileReader.
ConsumerStateStore Represents storage for ConsumerState.
StreamConfig Represents the configuration of a stream.
StreamConsumer Represents a transaction stream consumer.
StreamConsumerFactory Factory for creating StreamConsumer.
StreamConsumerState Represents the consumer state of a StreamConsumer.
StreamConsumerStateStore Represents storage for ConsumerState for stream consumers.
StreamConsumerStateStoreFactory Factory for creating StreamConsumerStateStore instance for different streams.

Classes in co.cask.cdap.data2.transaction.stream used by co.cask.cdap.data2.transaction.stream.inmemory

Class and Description
ConsumerStateStore Represents storage for ConsumerState.
StreamConfig Represents the configuration of a stream.
StreamConsumer Represents a transaction stream consumer.
StreamConsumerFactory Factory for creating StreamConsumer.
StreamConsumerStateStore Represents storage for ConsumerState for stream consumers.
StreamConsumerStateStoreFactory Factory for creating StreamConsumerStateStore instance for different streams.

Classes in co.cask.cdap.data2.transaction.stream used by co.cask.cdap.data2.transaction.stream.leveldb

Class and Description
AbstractStreamFileConsumer A StreamConsumer that read events from stream file and uses a table to store consumer states.
AbstractStreamFileConsumer.StateScanner Scanner for scanning state table.
AbstractStreamFileConsumerFactory Abstract base class for implementing StreamConsumerFactory using MultiLiveStreamFileReader.
ConsumerStateStore Represents storage for ConsumerState.
StreamConfig Represents the configuration of a stream.
StreamConsumer Represents a transaction stream consumer.
StreamConsumerFactory Factory for creating StreamConsumer.
StreamConsumerState Represents the consumer state of a StreamConsumer.
StreamConsumerStateStore Represents storage for ConsumerState for stream consumers.
StreamConsumerStateStoreFactory Factory for creating StreamConsumerStateStore instance for different streams.