co.cask.cdap.test.remote

Class RemoteApplicationManager

java.lang.Object

co.cask.cdap.test.remote.RemoteApplicationManager

All Implemented Interfaces:

ApplicationManager

public class RemoteApplicationManager
extends Object
implements ApplicationManager

Field Summary

Fields

Modifier and Type	Field and Description
protected Id.Application	application

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
<T> DataSetManager<T>	getDataSet(String dataSetName)
StreamWriter	getStreamWriter(String streamName) Deprecated.
FlowManager	startFlow(String flowName)
FlowManager	startFlow(String flowName, Map<String,String> arguments)
MapReduceManager	startMapReduce(String jobName)
MapReduceManager	startMapReduce(String jobName, Map<String,String> arguments)
ServiceManager	startService(String serviceName)
ServiceManager	startService(String serviceName, Map<String,String> arguments)
SparkManager	startSpark(String jobName)
SparkManager	startSpark(String jobName, Map<String,String> arguments)
WorkerManager	startWorker(String workerName)
WorkerManager	startWorker(String workerName, Map<String,String> arguments)
WorkflowManager	startWorkflow(String workflowName, Map<String,String> arguments)
void	stopAll()

Methods inherited from class java.lang.Object

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

Field Detail

application

protected final Id.Application application

Constructor Detail

RemoteApplicationManager

public RemoteApplicationManager(Id.Application application,
                        ClientConfig clientConfig)

Method Detail

startFlow

public FlowManager startFlow(String flowName)

Specified by:

startFlow in interface ApplicationManager

startFlow

public FlowManager startFlow(String flowName,
                    Map<String,String> arguments)

Specified by:

startFlow in interface ApplicationManager

startMapReduce

public MapReduceManager startMapReduce(String jobName)

Specified by:

startMapReduce in interface ApplicationManager

startMapReduce

public MapReduceManager startMapReduce(String jobName,
                              Map<String,String> arguments)

Specified by:

startMapReduce in interface ApplicationManager

startSpark

public SparkManager startSpark(String jobName)

Specified by:

startSpark in interface ApplicationManager

startSpark

public SparkManager startSpark(String jobName,
                      Map<String,String> arguments)

Specified by:

startSpark in interface ApplicationManager

startWorkflow

public WorkflowManager startWorkflow(String workflowName,
                            Map<String,String> arguments)

Specified by:

startWorkflow in interface ApplicationManager

startService

public ServiceManager startService(String serviceName)

Specified by:

startService in interface ApplicationManager

startService

public ServiceManager startService(String serviceName,
                          Map<String,String> arguments)

Specified by:

startService in interface ApplicationManager

startWorker

public WorkerManager startWorker(String workerName,
                        Map<String,String> arguments)

Specified by:

startWorker in interface ApplicationManager

startWorker

public WorkerManager startWorker(String workerName)

Specified by:

startWorker in interface ApplicationManager

getStreamWriter

@Deprecated
public StreamWriter getStreamWriter(String streamName)

Deprecated.

Specified by:

getStreamWriter in interface ApplicationManager

getDataSet

public <T> DataSetManager<T> getDataSet(String dataSetName)
                             throws Exception

Specified by:

getDataSet in interface ApplicationManager

Throws:

Exception

stopAll

public void stopAll()

Specified by:

stopAll in interface ApplicationManager