Uses of Package
co.cask.cdap.data.stream

Packages that use co.cask.cdap.data.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.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.leveldb	This package contains class for stream consumer implementation that uses LevelDB as state store.

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

Class and Description
StreamFileWriterFactory

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

Class and Description
AbstractStreamCoordinatorClient Base implementation for StreamCoordinatorClient.
CoordinatorStreamProperties This class carries stream properties used for coordination purpose.
PositionStreamEvent A StreamEvent which also carries the file position where this event starts.
StreamCoordinatorClient This class responsible for process coordination needed between stream writers and consumers.
StreamDataFileReader Class for reading data file written by StreamDataFileWriter.
StreamEventOffset This class is a StreamEvent that also carries the corresponding StreamFileOffset that mark the beginning offset of this stream event.
StreamFileOffset Represents offset information for single stream file.
StreamFileType An enum to distinguish different file types in stream data file.
StreamInputSplitFactory Factory for creating stream input splits.
StreamInputSplitFinder Finds input splits for a stream given several stream configuration settings and the location of the stream.
StreamInputSplitFinder.Builder Builder for creating a split finder.
StreamPropertyListener Listener for changes in stream properties.
TimePartitionedStreamFileWriter.TimePartition Uses timestamp to represent partition information.
TimestampCloseable A Closeable that also provides timestamp when the actual close operation happened.

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

Class and Description
StreamCoordinatorClient This class responsible for process coordination needed between stream writers and consumers.
StreamFileJanitor Performs deletion of unused stream files.
StreamFileWriterFactory
TimestampCloseable A Closeable that also provides timestamp when the actual close operation happened.

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

Class and Description
StreamCoordinatorClient This class responsible for process coordination needed between stream writers and consumers.
StreamEventOffset This class is a StreamEvent that also carries the corresponding StreamFileOffset that mark the beginning offset of this stream event.
StreamFileOffset Represents offset information for single stream file.

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

Class and Description
StreamEventOffset This class is a StreamEvent that also carries the corresponding StreamFileOffset that mark the beginning offset of this stream event.
StreamFileOffset Represents offset information for single stream file.

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

Class and Description
StreamEventOffset This class is a StreamEvent that also carries the corresponding StreamFileOffset that mark the beginning offset of this stream event.
StreamFileOffset Represents offset information for single stream file.