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(DiscoveryServiceClient discoveryServiceClient, AppFabricClient appFabricClient, MetricsManager metricsManager, co.cask.cdap.proto.Id.Application application)

Method Summary

Methods

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

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

startProgram

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultApplicationManager

@Inject
public DefaultApplicationManager(DiscoveryServiceClient discoveryServiceClient,
                                AppFabricClient appFabricClient,
                                MetricsManager metricsManager,
                                co.cask.cdap.proto.Id.Application application)

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)

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)

update

public void update(co.cask.cdap.proto.artifact.AppRequest appRequest)
            throws Exception

Throws:

Exception

delete

public void delete()
            throws Exception

Throws:

Exception

getInfo

public co.cask.cdap.proto.ApplicationDetail getInfo()
                                             throws Exception

Throws:

Exception

setRuntimeArgs

public void setRuntimeArgs(co.cask.cdap.proto.id.ProgramId programId,
                  Map<String,String> args)
                    throws Exception

Throws:

Exception