co.cask.cdap.test.remote

Class RemoteFlowManager

java.lang.Object

co.cask.cdap.test.AbstractProgramManager<FlowManager>

co.cask.cdap.test.remote.RemoteFlowManager

All Implemented Interfaces:

FlowManager, ProgramManager<FlowManager>

public class RemoteFlowManager
extends AbstractProgramManager<FlowManager>
implements FlowManager

Remote implementation of FlowManager.

Field Summary

Fields inherited from class co.cask.cdap.test.AbstractProgramManager

programId

Constructor Summary

Constructors

Constructor and Description
RemoteFlowManager(Id.Flow programId, ClientConfig clientConfig, RESTClient restClient, RemoteApplicationManager applicationManager)

Method Summary

Methods

Modifier and Type	Method and Description
int	getFlowletInstances(String flowletName)
RuntimeMetrics	getFlowletMetrics(String flowletId)
void	setFlowletInstances(String flowletName, int instances)

Methods inherited from class co.cask.cdap.test.AbstractProgramManager

getHistory, getHistory, isRunning, start, start, stop, waitForFinish, waitForStatus, waitForStatus, waitForStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.cdap.test.ProgramManager

getHistory, getHistory, isRunning, start, start, stop, waitForFinish, waitForStatus, waitForStatus

Constructor Detail

RemoteFlowManager

public RemoteFlowManager(Id.Flow programId,
                 ClientConfig clientConfig,
                 RESTClient restClient,
                 RemoteApplicationManager applicationManager)

Method Detail

setFlowletInstances

public void setFlowletInstances(String flowletName,
                       int instances)

Specified by:

setFlowletInstances in interface FlowManager

getFlowletInstances

public int getFlowletInstances(String flowletName)

Specified by:

getFlowletInstances in interface FlowManager

getFlowletMetrics

public RuntimeMetrics getFlowletMetrics(String flowletId)

Specified by:

getFlowletMetrics in interface FlowManager