co.cask.cdap.test.internal

Class DefaultApplicationManager

java.lang.Object

co.cask.cdap.test.internal.DefaultApplicationManager

All Implemented Interfaces:

ApplicationManager

public class DefaultApplicationManager
extends Object
implements ApplicationManager

A default implementation of ApplicationManager.

Constructor Summary

Constructors

Constructor and Description

DefaultApplicationManager(co.cask.cdap.data2.dataset2.DatasetFramework datasetFramework, co.cask.tephra.TransactionSystemClient txSystemClient, StreamWriterFactory streamWriterFactory, ProcedureClientFactory procedureClientFactory, org.apache.twill.discovery.DiscoveryServiceClient discoveryServiceClient, org.junit.rules.TemporaryFolder tempFolder, AppFabricClient appFabricClient, co.cask.cdap.proto.Id.Application applicationId, org.apache.twill.filesystem.Location deployedJar)

Method Summary

Methods

Modifier and Type	Method and Description
<T> DataSetManager<T>	getDataSet(String dataSetName)
StreamWriter	getStreamWriter(String streamName)
FlowManager	startFlow(String flowName)
FlowManager	startFlow(String flowName, Map<String,String> arguments)
MapReduceManager	startMapReduce(String jobName)
MapReduceManager	startMapReduce(String jobName, Map<String,String> arguments)
ProcedureManager	startProcedure(String procedureName)
ProcedureManager	startProcedure(String procedureName, 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

Constructor Detail

DefaultApplicationManager

@Inject
public DefaultApplicationManager(co.cask.cdap.data2.dataset2.DatasetFramework datasetFramework,
                                co.cask.tephra.TransactionSystemClient txSystemClient,
                                StreamWriterFactory streamWriterFactory,
                                ProcedureClientFactory procedureClientFactory,
                                org.apache.twill.discovery.DiscoveryServiceClient discoveryServiceClient,
                                org.junit.rules.TemporaryFolder tempFolder,
                                AppFabricClient appFabricClient,
                                co.cask.cdap.proto.Id.Application applicationId,
                                org.apache.twill.filesystem.Location deployedJar)

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

startProcedure

public ProcedureManager startProcedure(String procedureName)

Specified by:

startProcedure in interface ApplicationManager

startProcedure

public ProcedureManager startProcedure(String procedureName,
                              Map<String,String> arguments)

Specified by:

startProcedure 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)

Specified by:

startWorker in interface ApplicationManager

startWorker

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

Specified by:

startWorker in interface ApplicationManager

getStreamWriter

public StreamWriter getStreamWriter(String streamName)

Specified by:

getStreamWriter in interface ApplicationManager

getDataSet

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

Specified by:

getDataSet in interface ApplicationManager

stopAll

public void stopAll()

Specified by:

stopAll in interface ApplicationManager