co.cask.cdap.test

Interface FlowManager

public interface FlowManager

Instance for this class is for managing a running Flow.

Method Summary

Methods

Modifier and Type	Method and Description
void	setFlowletInstances(String flowletName, int instances) Changes the number of flowlet instances.
void	stop() Stops the running flow.

Method Detail

setFlowletInstances

void setFlowletInstances(String flowletName,
                       int instances)

Changes the number of flowlet instances.

Parameters:

flowletName - Name of the flowlet.

instances - Number of instances to change to.

stop

void stop()

Stops the running flow.