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

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
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