co.cask.cdap.data.stream.service

Class LocalStreamService

java.lang.Object

com.google.common.util.concurrent.AbstractScheduledService

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

co.cask.cdap.data.stream.service.LocalStreamService

All Implemented Interfaces:

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

public class LocalStreamService
extends AbstractStreamService

Stream service running in local mode.

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
LocalStreamService(StreamCoordinatorClient streamCoordinatorClient, StreamFileJanitorService janitorService, StreamMetaStore streamMetaStore, StreamAdmin streamAdmin, StreamWriterSizeCollector streamWriterSizeCollector, 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

LocalStreamService

@Inject
public LocalStreamService(StreamCoordinatorClient streamCoordinatorClient,
                         StreamFileJanitorService janitorService,
                         StreamMetaStore streamMetaStore,
                         StreamAdmin streamAdmin,
                         StreamWriterSizeCollector streamWriterSizeCollector,
                         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