co.cask.tigon.test
Class DefaultFlowManager

java.lang.Object
  co.cask.tigon.test.DefaultFlowManager

All Implemented Interfaces:

FlowManager

public class DefaultFlowManager
extends Object
implements FlowManager

Default Flow Manager.

Constructor Summary

DefaultFlowManager(co.cask.tigon.internal.app.runtime.ProgramController controller)

Method Summary

void	setFlowletInstances(String flowletName, int instances) Changes the number of flowlet instances.
void	stop() Stops the running flow.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultFlowManager

public DefaultFlowManager(co.cask.tigon.internal.app.runtime.ProgramController controller)

Method Detail

setFlowletInstances

public void setFlowletInstances(String flowletName,
                                int instances)

Description copied from interface: FlowManager

Changes the number of flowlet instances.

Specified by:

setFlowletInstances in interface FlowManager

Parameters:

flowletName - Name of the flowlet.

instances - Number of instances to change to.

stop

public void stop()

Description copied from interface: FlowManager

Stops the running flow.

Specified by:

stop in interface FlowManager