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 flowName, co.cask.cdap.test.internal.DefaultApplicationManager.ProgramId flowID, String applicationId, AppFabricClient appFabricClient, DefaultApplicationManager applicationManager)

Method Summary

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 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

stop

public void stop()

Specified by:

stop in interface FlowManager

isRunning

public boolean isRunning()

Specified by:

isRunning in interface FlowManager