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

AbstractApplicationManager for use in integration tests.

Field Summary

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

application

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	delete()
FlowManager	getFlowManager(String flowName)
List<RunRecord>	getHistory(ProgramId programId, ProgramRunStatus status)
ApplicationDetail	getInfo()
MapReduceManager	getMapReduceManager(String programName)
List<PluginInstanceDetail>	getPlugins()
Map<String,String>	getRuntimeArgs(ProgramId programId)
ServiceManager	getServiceManager(String serviceName)
SparkManager	getSparkManager(String jobName)
WorkerManager	getWorkerManager(String workerName)
WorkflowManager	getWorkflowManager(String workflowName)
boolean	isRunning(ProgramId programId)
void	setRuntimeArgs(ProgramId programId, Map<String,String> args)
void	startProgram(ProgramId programId, Map<String,String> arguments)
void	stopAll()
void	stopProgram(ProgramId programId)
void	update(AppRequest appRequest)

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

getHistory, isRunning, startProgram, startProgram, startProgram, stopProgram

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteApplicationManager

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

Deprecated.

RemoteApplicationManager

public RemoteApplicationManager(ApplicationId 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)

getPlugins

public List<PluginInstanceDetail> getPlugins()

stopAll

public void stopAll()

stopProgram

public void stopProgram(ProgramId programId)

startProgram

public void startProgram(ProgramId programId,
                Map<String,String> arguments)

isRunning

public boolean isRunning(ProgramId programId)

getHistory

public List<RunRecord> getHistory(ProgramId programId,
                         ProgramRunStatus status)

update

public void update(AppRequest appRequest)
            throws Exception

Throws:

Exception

delete

public void delete()
            throws Exception

Throws:

Exception

getInfo

public ApplicationDetail getInfo()
                          throws Exception

Throws:

Exception

setRuntimeArgs

public void setRuntimeArgs(ProgramId programId,
                  Map<String,String> args)
                    throws Exception

Throws:

Exception

getRuntimeArgs

public Map<String,String> getRuntimeArgs(ProgramId programId)
                                  throws Exception

Throws:

Exception