co.cask.cdap.test.internal

Class DefaultWorkflowManager

java.lang.Object

co.cask.cdap.test.AbstractProgramManager<WorkflowManager>

co.cask.cdap.test.internal.DefaultWorkflowManager

All Implemented Interfaces:

ProgramManager<WorkflowManager>, WorkflowManager

public class DefaultWorkflowManager
extends AbstractProgramManager<WorkflowManager>
implements WorkflowManager

A default implementation of FlowManager.

Field Summary

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

programId

Constructor Summary

Constructors

Constructor and Description
DefaultWorkflowManager(co.cask.cdap.proto.Id.Program programId, AppFabricClient appFabricClient, DefaultApplicationManager applicationManager)

Method Summary

Methods

Modifier and Type	Method and Description
ScheduleManager	getSchedule(String schedName)
List<ScheduleSpecification>	getSchedules()
co.cask.cdap.proto.WorkflowTokenDetail	getToken(String runId, WorkflowToken.Scope scope, String key)
co.cask.cdap.proto.WorkflowTokenNodeDetail	getTokenAtNode(String runId, String nodeName, WorkflowToken.Scope scope, String key)

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

getHistory, getHistory, isRunning, start, start, stop, waitForFinish, waitForStatus, waitForStatus, waitForStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.cdap.test.ProgramManager

getHistory, getHistory, isRunning, start, start, stop, waitForFinish, waitForStatus, waitForStatus

Constructor Detail

DefaultWorkflowManager

public DefaultWorkflowManager(co.cask.cdap.proto.Id.Program programId,
                      AppFabricClient appFabricClient,
                      DefaultApplicationManager applicationManager)

Method Detail

getSchedules

public List<ScheduleSpecification> getSchedules()

Specified by:

getSchedules in interface WorkflowManager

getToken

public co.cask.cdap.proto.WorkflowTokenDetail getToken(String runId,
                                              @Nullable
                                              WorkflowToken.Scope scope,
                                              @Nullable
                                              String key)
                                                throws co.cask.cdap.common.NotFoundException

Specified by:

getToken in interface WorkflowManager

Throws:

co.cask.cdap.common.NotFoundException

getTokenAtNode

public co.cask.cdap.proto.WorkflowTokenNodeDetail getTokenAtNode(String runId,
                                                        String nodeName,
                                                        @Nullable
                                                        WorkflowToken.Scope scope,
                                                        @Nullable
                                                        String key)
                                                          throws co.cask.cdap.common.NotFoundException

Specified by:

getTokenAtNode in interface WorkflowManager

Throws:

co.cask.cdap.common.NotFoundException

getSchedule

public ScheduleManager getSchedule(String schedName)

Specified by:

getSchedule in interface WorkflowManager