public class RemoteApplicationManager extends AbstractApplicationManager
application| Constructor and Description |
|---|
RemoteApplicationManager(Id.Application application,
ClientConfig clientConfig,
RESTClient restClient) |
| Modifier and Type | Method and Description |
|---|---|
FlowManager |
getFlowManager(String flowName) |
List<RunRecord> |
getHistory(Id.Program programId,
ProgramRunStatus status) |
MapReduceManager |
getMapReduceManager(String programName) |
ServiceManager |
getServiceManager(String serviceName) |
SparkManager |
getSparkManager(String jobName) |
WorkerManager |
getWorkerManager(String workerName) |
WorkflowManager |
getWorkflowManager(String workflowName) |
boolean |
isRunning(Id.Program programId) |
void |
startProgram(Id.Program programId,
Map<String,String> arguments) |
void |
stopAll() |
void |
stopProgram(Id.Program programId) |
startProgrampublic RemoteApplicationManager(Id.Application application, ClientConfig clientConfig, RESTClient restClient)
public FlowManager getFlowManager(String flowName)
public MapReduceManager getMapReduceManager(String programName)
public SparkManager getSparkManager(String jobName)
public WorkflowManager getWorkflowManager(String workflowName)
public ServiceManager getServiceManager(String serviceName)
public WorkerManager getWorkerManager(String workerName)
public void stopAll()
public void stopProgram(Id.Program programId)
public void startProgram(Id.Program programId, Map<String,String> arguments)
public boolean isRunning(Id.Program programId)
public List<RunRecord> getHistory(Id.Program programId, ProgramRunStatus status)
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.