co.cask.cdap.data.stream

Class StreamServiceManager

java.lang.Object

co.cask.cdap.common.twill.AbstractDistributedMasterServiceManager

co.cask.cdap.data.stream.StreamServiceManager

All Implemented Interfaces:

MasterServiceManager

public class StreamServiceManager
extends AbstractDistributedMasterServiceManager

CDAP Stream Service management in distributed mode.

Field Summary

Fields inherited from class co.cask.cdap.common.twill.AbstractDistributedMasterServiceManager

cConf, discoveryServiceClient, discoveryTimeout, serviceName, twillRunnerService

Constructor Summary

Constructors

Constructor and Description
StreamServiceManager(CConfiguration cConf, TwillRunnerService twillRunnerService, DiscoveryServiceClient discoveryServiceClient)

Method Summary

Methods

Modifier and Type	Method and Description
String	getDescription()
int	getMaxInstances()

Methods inherited from class co.cask.cdap.common.twill.AbstractDistributedMasterServiceManager

canCheckStatus, checkGetStatus, getDiscoverableName, getInstances, getLiveInfo, getMinInstances, isLogAvailable, isServiceAvailable, isServiceEnabled, restartAllInstances, restartInstances, setInstances

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamServiceManager

@Inject
public StreamServiceManager(CConfiguration cConf,
                           TwillRunnerService twillRunnerService,
                           DiscoveryServiceClient discoveryServiceClient)

Method Detail

getMaxInstances

public int getMaxInstances()

getDescription

public String getDescription()