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

See: Description

Interface Summary

Interface	Description
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	Factory for creating StreamMetricsCollectorFactory.StreamMetricsCollectors.
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.

Class Summary

Class	Description
AbstractStreamService	Stream service meant to run in an HTTP service.
BasicStreamWriterSizeCollector	Basic implementation of a StreamWriterSizeCollector.
ConcurrentStreamWriter	Class to support writing to stream with high concurrency.
DistributedStreamFileJanitorService	Performs leader election and the leader will do stream file cleanup using LocalStreamFileJanitorService.
DistributedStreamService	Stream service running in a TwillRunnable.
InMemoryStreamMetaStore	In-memory implementation of the StreamMetaStore.
LocalStreamFileJanitorService	Performs cleanup of stream files regularly with a single thread executor.
LocalStreamService	Stream service running in local mode.
MDSStreamMetaStore	Implementation of StreamMetaStore that access MDS directly.
MutableStreamEvent	A mutable StreamEvent that allows setting the data and timestamp.
MutableStreamEventData	A mutable StreamEventData that allows setting header and body.
StreamFetchHandler	A HTTP handler for handling getting stream events.
StreamHandler	The HttpHandler for handling REST call to V3 stream APIs.
StreamHttpService	A Http service endpoint that host the stream handler.
StreamServiceModule	Base module for stream service bindings
StreamServiceRuntimeModule	Defines Guice modules in different runtime environments.

Package co.cask.cdap.data.stream.service Description

This package contains class for running stream http service as well as twill runnable for running the service in YARN.