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

This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.

See: Description

Interface Summary

Interface	Description
AbstractStreamFileConsumer.StateScanner	Scanner for scanning state table.
ConsumerState<T>	Represents state of a consumer.
ConsumerStateStore<S extends ConsumerState<T>,T>	Represents storage for ConsumerState.
StreamAdmin
StreamConsumer	Represents a transaction stream consumer.
StreamConsumerFactory	Factory for creating StreamConsumer.
StreamConsumerStateStoreFactory	Factory for creating StreamConsumerStateStore instance for different streams.

Class Summary

Class	Description
AbstractStreamFileConsumer	A StreamConsumer that read events from stream file and uses a table to store consumer states.
AbstractStreamFileConsumerFactory	Abstract base class for implementing StreamConsumerFactory using MultiLiveStreamFileReader.
FileStreamAdmin	An abstract base StreamAdmin for File based stream.
ForwardingStreamConsumer	A StreamConsumer that forwards every methods to another StreamConsumer.
QueueToStreamConsumer	An adapter from Queue2Consumer to StreamConsumer.
StreamConfig	Represents the configuration of a stream.
StreamConfig.Builder	A builder to help building instance of StreamConfig.
StreamConsumerState	Represents the consumer state of a StreamConsumer.
StreamConsumerStateStore	Represents storage for ConsumerState for stream consumers.

Package co.cask.cdap.data2.transaction.stream Description

This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.