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

Packages that use StreamFileJanitorService

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 StreamFileJanitorService in co.cask.cdap.data.stream.service

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

Modifier and Type	Class and Description
class	DistributedStreamFileJanitorService Performs leader election and the leader will do stream file cleanup using LocalStreamFileJanitorService.
class	LocalStreamFileJanitorService Performs cleanup of stream files regularly with a single thread executor.

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

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)