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

Packages that use co.cask.cdap.data.stream.service

Package	Description
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.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.

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

Class and Description
AbstractStreamService Stream service meant to run in an HTTP service.
MutableStreamEvent A mutable StreamEvent that allows setting the data and timestamp.
MutableStreamEventData A mutable StreamEventData that allows setting header and body.
StreamFileJanitorService Represents a service that would performs cleanup of stream file when it is started.
StreamMetaStore A temporary place for hosting MDS access logic for streams.
StreamMetricsCollectorFactory.StreamMetricsCollector Collector of metrics for a stream.
StreamService Stream service interface, that exists only for Streams on files.
StreamWriterSizeCollector Keep track of the sizes of the files written by one StreamHandler.

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

Class and Description
ConcurrentStreamWriter Class to support writing to stream with high concurrency.

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

Class and Description
StreamMetaStore A temporary place for hosting MDS access logic for streams.

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

Class and Description
StreamMetaStore A temporary place for hosting MDS access logic for streams.