co.cask.cdap.test.internal

Class DefaultApplicationManager

java.lang.Object

co.cask.cdap.test.AbstractApplicationManager

co.cask.cdap.test.internal.DefaultApplicationManager

All Implemented Interfaces:

ApplicationManager

public class DefaultApplicationManager
extends AbstractApplicationManager

A default implementation of ApplicationManager.

Field Summary

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

application

Constructor Summary

Constructors

Constructor and Description

DefaultApplicationManager(co.cask.cdap.common.conf.CConfiguration cConf, co.cask.cdap.data2.dataset2.DatasetFramework datasetFramework, co.cask.tephra.TransactionSystemClient txSystemClient, StreamWriterFactory streamWriterFactory, DiscoveryServiceClient discoveryServiceClient, org.junit.rules.TemporaryFolder tempFolder, AppFabricClient appFabricClient, MetricsManager metricsManager, co.cask.cdap.proto.Id.Application application, Location deployedJar)

Method Summary

Methods

Modifier and Type	Method and Description
<T> DataSetManager<T>	getDataSet(String dataSetName)
FlowManager	getFlowManager(String flowName)
List<co.cask.cdap.proto.RunRecord>	getHistory(co.cask.cdap.proto.Id.Program programId, co.cask.cdap.proto.ProgramRunStatus status)
MapReduceManager	getMapReduceManager(String programName)
ServiceManager	getServiceManager(String serviceName)
SparkManager	getSparkManager(String jobName)
StreamWriter	getStreamWriter(String streamName) Deprecated.
WorkerManager	getWorkerManager(String workerName)
WorkflowManager	getWorkflowManager(String workflowName)
boolean	isRunning(co.cask.cdap.proto.Id.Program programId)
void	startProgram(co.cask.cdap.proto.Id.Program programId, Map<String,String> arguments)
void	stopAll()
void	stopProgram(co.cask.cdap.proto.Id.Program programId)

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

startFlow, startFlow, startMapReduce, startMapReduce, startProgram, startService, startService, startSpark, startSpark, startWorker, startWorker, startWorkflow

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.common.conf.CConfiguration cConf,
                                co.cask.cdap.data2.dataset2.DatasetFramework datasetFramework,
                                co.cask.tephra.TransactionSystemClient txSystemClient,
                                StreamWriterFactory streamWriterFactory,
                                DiscoveryServiceClient discoveryServiceClient,
                                org.junit.rules.TemporaryFolder tempFolder,
                                AppFabricClient appFabricClient,
                                MetricsManager metricsManager,
                                co.cask.cdap.proto.Id.Application application,
                                Location deployedJar)

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)

getStreamWriter

@Deprecated
public StreamWriter getStreamWriter(String streamName)

Deprecated.

getDataSet

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

stopAll

public void stopAll()

stopProgram

public void stopProgram(co.cask.cdap.proto.Id.Program programId)

startProgram

public void startProgram(co.cask.cdap.proto.Id.Program programId,
                Map<String,String> arguments)

isRunning

public boolean isRunning(co.cask.cdap.proto.Id.Program programId)

getHistory

public List<co.cask.cdap.proto.RunRecord> getHistory(co.cask.cdap.proto.Id.Program programId,
                                            co.cask.cdap.proto.ProgramRunStatus status)