co.cask.cdap.test.internal

Class DefaultFlowManager

java.lang.Object

co.cask.cdap.test.AbstractProgramManager<FlowManager>

co.cask.cdap.test.internal.DefaultFlowManager

All Implemented Interfaces:

FlowManager, ProgramManager<FlowManager>

public class DefaultFlowManager
extends AbstractProgramManager<FlowManager>
implements FlowManager

A default implementation of FlowManager.

Field Summary

Fields inherited from class co.cask.cdap.test.AbstractProgramManager

programId

Constructor Summary

Constructors

Constructor and Description
DefaultFlowManager(co.cask.cdap.proto.Id.Program programId, AppFabricClient appFabricClient, DefaultApplicationManager applicationManager, MetricsManager metricsManager)

Method Summary

Methods

Modifier and Type	Method and Description
int	getFlowletInstances(String flowletName)
RuntimeMetrics	getFlowletMetrics(String flowletId)
void	setFlowletInstances(String flowletName, int instances)

Methods inherited from class co.cask.cdap.test.AbstractProgramManager

getHistory, getHistory, isRunning, start, start, stop, waitForFinish, waitForStatus, waitForStatus, waitForStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.cdap.test.ProgramManager

getHistory, getHistory, isRunning, start, start, stop, waitForFinish, waitForStatus, waitForStatus

Constructor Detail

DefaultFlowManager

public DefaultFlowManager(co.cask.cdap.proto.Id.Program programId,
                  AppFabricClient appFabricClient,
                  DefaultApplicationManager applicationManager,
                  MetricsManager metricsManager)

Method Detail

setFlowletInstances

public void setFlowletInstances(String flowletName,
                       int instances)

Specified by:

setFlowletInstances in interface FlowManager

getFlowletInstances

public int getFlowletInstances(String flowletName)

Specified by:

getFlowletInstances in interface FlowManager

getFlowletMetrics

public RuntimeMetrics getFlowletMetrics(String flowletId)

Specified by:

getFlowletMetrics in interface FlowManager