co.cask.cdap.data.stream.service

Class DistributedStreamService

java.lang.Object

com.google.common.util.concurrent.AbstractScheduledService

co.cask.cdap.data.stream.service.AbstractStreamService

co.cask.cdap.data.stream.service.DistributedStreamService

All Implemented Interfaces:

StreamService, com.google.common.util.concurrent.Service

public class DistributedStreamService
extends AbstractStreamService

Stream service running in a TwillRunnable. It is responsible for sending StreamWriterHeartbeats at a fixed rate, describing the sizes of the stream files on which this service writes data, for each stream.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.common.util.concurrent.AbstractScheduledService

com.google.common.util.concurrent.AbstractScheduledService.CustomScheduler, com.google.common.util.concurrent.AbstractScheduledService.Scheduler

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

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)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doShutdown() Children classes should implement this method to add logic to the shutdown of this Service.
protected void	initialize() Children classes should implement this method to add logic to the start of this Service.
protected void	runOneIteration()

Methods inherited from class co.cask.cdap.data.stream.service.AbstractStreamService

executor, getStreamCoordinatorClient, getStreamEventsSize, scheduler, shutDown, startUp

Methods inherited from class com.google.common.util.concurrent.AbstractScheduledService

addListener, isRunning, start, startAndWait, state, stop, stopAndWait, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, isRunning, start, startAndWait, state, stop, stopAndWait

Constructor Detail

DistributedStreamService

@Inject
public 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)

Method Detail

initialize

protected void initialize()
                   throws Exception

Description copied from class: AbstractStreamService

Children classes should implement this method to add logic to the start of this Service.

Specified by:

initialize in class AbstractStreamService

Throws:

Exception - in case of any error while initializing

doShutdown

protected void doShutdown()
                   throws Exception

Description copied from class: AbstractStreamService

Children classes should implement this method to add logic to the shutdown of this Service.

Specified by:

doShutdown in class AbstractStreamService

Throws:

Exception - in case of any error while shutting down

runOneIteration

protected void runOneIteration()
                        throws Exception

Specified by:

runOneIteration in class com.google.common.util.concurrent.AbstractScheduledService

Throws:

Exception