|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface FlowStep<Config>
Class FlowStep is an internal representation of a given "job" possibly to be executed on a remote cluster. During planning, pipe assemblies are broken down into "steps" and encapsulated in this class.
FlowSteps are submitted in order of dependency. If two or more steps do not share the same dependencies and all can be scheduled simultaneously, thegetSubmitPriority()
value determines the order in which
all steps will be submitted for execution. The default submit priority is 5.
Field Summary | |
---|---|
static String |
CASCADING_FLOW_STEP_ID
|
Method Summary | |
---|---|
boolean |
containsPipeNamed(String pipeName)
Returns true if this FlowStep contains a pipe/branch with the given name. |
Set<Tap> |
getAllAccumulatedSources()
|
Config |
getConfig()
Method getConfig returns the current initialized configuration. |
Flow<Config> |
getFlow()
|
String |
getFlowID()
|
String |
getFlowName()
Method getParentFlowName returns the parentFlowName of this FlowStep object. |
FlowStepStats |
getFlowStepStats()
|
Group |
getGroup()
|
List<Group> |
getGroups()
|
String |
getID()
Method getId returns the id of this FlowStep object. |
String |
getName()
Method getName returns the name of this FlowStep object. |
Tap |
getSink()
|
Set<String> |
getSinkName(Tap sink)
|
Set<Tap> |
getSinks()
|
Tap |
getSinkWith(String identifier)
|
Set<String> |
getSourceName(Tap source)
|
Set<Tap> |
getSources()
|
Tap |
getSourceWith(String identifier)
|
String |
getStepDisplayName()
Method getStepDisplayName returns the stepDisplayName of this FlowStep object. |
int |
getStepNum()
|
Map<HashJoin,Tap> |
getStreamedSourceByJoin()
|
int |
getSubmitPriority()
Method getSubmitPriority returns the submitPriority of this FlowStep object. |
Tap |
getTrap(String name)
|
Set<Tap> |
getTraps()
|
void |
setSubmitPriority(int submitPriority)
Method setSubmitPriority sets the submitPriority of this FlowStep object. |
Field Detail |
---|
static final String CASCADING_FLOW_STEP_ID
Method Detail |
---|
String getID()
int getStepNum()
String getName()
Flow<Config> getFlow()
String getFlowID()
String getFlowName()
Config getConfig()
String getStepDisplayName()
int getSubmitPriority()
void setSubmitPriority(int submitPriority)
submitPriority
- the submitPriority of this FlowStep object.Group getGroup()
List<Group> getGroups()
Map<HashJoin,Tap> getStreamedSourceByJoin()
Set<Tap> getAllAccumulatedSources()
Set<Tap> getSources()
Set<Tap> getSinks()
Tap getSink()
Set<String> getSourceName(Tap source)
Set<String> getSinkName(Tap sink)
Tap getSourceWith(String identifier)
Tap getSinkWith(String identifier)
Set<Tap> getTraps()
Tap getTrap(String name)
boolean containsPipeNamed(String pipeName)
pipeName
- the name of the Pipe
FlowStepStats getFlowStepStats()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |