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

DefaultApplicationManager(org.apache.twill.filesystem.LocationFactory locationFactory, co.cask.cdap.data2.dataset2.DatasetFramework datasetFramework, co.cask.tephra.TransactionSystemClient txSystemClient, StreamWriterFactory streamWriterFactory, ProcedureClientFactory procedureClientFactory, co.cask.cdap.common.conf.CConfiguration configuration, org.apache.twill.discovery.DiscoveryServiceClient discoveryServiceClient, AppFabricHttpHandler httpHandler, ServiceHttpHandler serviceHttpHandler, org.junit.rules.TemporaryFolder tempFolder, String accountId, String applicationId, org.apache.twill.filesystem.Location deployedJar)

Method Summary

<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)
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(org.apache.twill.filesystem.LocationFactory locationFactory,
                                        co.cask.cdap.data2.dataset2.DatasetFramework datasetFramework,
                                        co.cask.tephra.TransactionSystemClient txSystemClient,
                                        StreamWriterFactory streamWriterFactory,
                                        ProcedureClientFactory procedureClientFactory,
                                        co.cask.cdap.common.conf.CConfiguration configuration,
                                        org.apache.twill.discovery.DiscoveryServiceClient discoveryServiceClient,
                                        AppFabricHttpHandler httpHandler,
                                        ServiceHttpHandler serviceHttpHandler,
                                        org.junit.rules.TemporaryFolder tempFolder,
                                        String accountId,
                                        String 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

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