co.cask.cdap.test.internal
Class DefaultFlowManager

java.lang.Object
  co.cask.cdap.test.internal.DefaultFlowManager

All Implemented Interfaces:

FlowManager

public class DefaultFlowManager
extends Object
implements FlowManager

A default implementation of FlowManager.

Constructor Summary

DefaultFlowManager(String namespace, String flowName, co.cask.cdap.test.internal.DefaultApplicationManager.ProgramId flowID, String applicationId, AppFabricClient appFabricClient, DefaultApplicationManager applicationManager)

Method Summary

RuntimeMetrics	getFlowletMetrics(String flowletId)
boolean	isRunning()
void	setFlowletInstances(String flowletName, int instances)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultFlowManager

public DefaultFlowManager(String namespace,
                          String flowName,
                          co.cask.cdap.test.internal.DefaultApplicationManager.ProgramId flowID,
                          String applicationId,
                          AppFabricClient appFabricClient,
                          DefaultApplicationManager applicationManager)

Method Detail

setFlowletInstances

public void setFlowletInstances(String flowletName,
                                int instances)

Specified by:

setFlowletInstances in interface FlowManager

getFlowletMetrics

public RuntimeMetrics getFlowletMetrics(String flowletId)

Specified by:

getFlowletMetrics in interface FlowManager

stop

public void stop()

Specified by:

stop in interface FlowManager

isRunning

public boolean isRunning()

Specified by:

isRunning in interface FlowManager