Uses of Interface
co.cask.cdap.data.stream.service.StreamWriterSizeCollector

Packages that use StreamWriterSizeCollector

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.

Uses of StreamWriterSizeCollector in co.cask.cdap.data.stream.service

Classes in co.cask.cdap.data.stream.service that implement StreamWriterSizeCollector

Modifier and Type	Class and Description
class	BasicStreamWriterSizeCollector Basic implementation of a StreamWriterSizeCollector.

Constructors in co.cask.cdap.data.stream.service with parameters of type StreamWriterSizeCollector

Constructor and Description
AbstractStreamService(StreamCoordinatorClient streamCoordinatorClient, StreamFileJanitorService janitorService, StreamWriterSizeCollector sizeCollector, MetricStore metricStore)
DistributedStreamService(CConfiguration cConf, StreamAdmin streamAdmin, StreamCoordinatorClient streamCoordinatorClient, StreamFileJanitorService janitorService, ZKClient zkClient, DiscoveryServiceClient discoveryServiceClient, StreamMetaStore streamMetaStore, com.google.common.base.Supplier<Discoverable> discoverableSupplier, StreamWriterSizeCollector streamWriterSizeCollector, HeartbeatPublisher heartbeatPublisher, NotificationFeedManager feedManager, NotificationService notificationService, MetricStore metricStore)
LocalStreamService(StreamCoordinatorClient streamCoordinatorClient, StreamFileJanitorService janitorService, StreamMetaStore streamMetaStore, StreamAdmin streamAdmin, StreamWriterSizeCollector streamWriterSizeCollector, NotificationService notificationService, MetricStore metricStore)
StreamHandler(CConfiguration cConf, StreamCoordinatorClient streamCoordinatorClient, StreamAdmin streamAdmin, StreamFileWriterFactory writerFactory, MetricsCollectionService metricsCollectionService, StreamWriterSizeCollector sizeCollector, AbstractNamespaceClient namespaceClient)