co.cask.cdap.test.remote

Class RemoteApplicationManager

java.lang.Object

co.cask.cdap.test.AbstractApplicationManager

co.cask.cdap.test.remote.RemoteApplicationManager

All Implemented Interfaces:

ApplicationManager

public class RemoteApplicationManager
extends AbstractApplicationManager

Field Summary

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

application

Constructor Summary

Constructors

Constructor and Description
RemoteApplicationManager(Id.Application application, ClientConfig clientConfig, RESTClient restClient)

Method Summary

Methods

Modifier and Type	Method and Description
FlowManager	getFlowManager(String flowName)
List<RunRecord>	getHistory(Id.Program programId, ProgramRunStatus status)
MapReduceManager	getMapReduceManager(String programName)
ServiceManager	getServiceManager(String serviceName)
SparkManager	getSparkManager(String jobName)
WorkerManager	getWorkerManager(String workerName)
WorkflowManager	getWorkflowManager(String workflowName)
boolean	isRunning(Id.Program programId)
void	startProgram(Id.Program programId, Map<String,String> arguments)
void	stopAll()
void	stopProgram(Id.Program programId)

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

startProgram

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteApplicationManager

public RemoteApplicationManager(Id.Application application,
                        ClientConfig clientConfig,
                        RESTClient restClient)

Method Detail

getFlowManager

public FlowManager getFlowManager(String flowName)

getMapReduceManager

public MapReduceManager getMapReduceManager(String programName)

getSparkManager

public SparkManager getSparkManager(String jobName)

getWorkflowManager

public WorkflowManager getWorkflowManager(String workflowName)

getServiceManager

public ServiceManager getServiceManager(String serviceName)

getWorkerManager

public WorkerManager getWorkerManager(String workerName)

stopAll

public void stopAll()

stopProgram

public void stopProgram(Id.Program programId)

startProgram

public void startProgram(Id.Program programId,
                Map<String,String> arguments)

isRunning

public boolean isRunning(Id.Program programId)

getHistory

public List<RunRecord> getHistory(Id.Program programId,
                         ProgramRunStatus status)