Uses of Interface
co.cask.cdap.data.stream.service.heartbeat.HeartbeatPublisher

Packages that use HeartbeatPublisher

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

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

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

Constructor and Description

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)

Uses of HeartbeatPublisher in co.cask.cdap.data.stream.service.heartbeat

Classes in co.cask.cdap.data.stream.service.heartbeat that implement HeartbeatPublisher

Modifier and Type	Class and Description
class	NoOpHeartbeatPublisher No-op implementation, to remove once notifications are here.
class	NotificationHeartbeatPublisher Implementation of HeartbeatPublisher that publishes StreamWriterHeartbeat as notification using the NotificationService.