NAMESPACE, PEGASUS, REFINEMENT_CLUSTER, REFINEMENT_REDUCE, REFINEMENT_REGISTER, REFINEMENT_SITE_SELECT, REFINEMENT_STAGE
Constructor and Description |
---|
Empty() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
beginWorkflowRefinementStep(Refiner refiner,
java.lang.String refinementStepName,
boolean firstStep) |
void |
clusteringOf(java.lang.String clusteredJob,
java.util.List jobs)
clusteringOf
|
void |
endWorkflowRefinementStep(Refiner refiner)
endWorkflowRefinementStep
|
void |
isIdenticalTo(java.lang.String afterNode,
java.lang.String beforeNode)
isIdenticalTo
|
void |
isPartitionOf(java.lang.String afterNode,
java.util.List beforeNode)
isPartitionOf
|
void |
registrationIntroducedFor(java.lang.String registrationNode,
java.lang.String dataStagingNode)
registrationIntroducedFor
|
void |
siteSelectionFor(java.lang.String afterNode,
java.lang.String beforeNode)
siteSelectionFor
|
void |
stagingIntroducedFor(java.util.List stagingNodes,
java.lang.String appNode)
stagingIntroducedFor
|
public java.lang.String beginWorkflowRefinementStep(Refiner refiner, java.lang.String refinementStepName, boolean firstStep) throws java.lang.Exception
beginWorkflowRefinementStep
in interface PPS
refiner
- workflow RefinerrefinementStepName
- StringfirstStep
- booleanjava.lang.Exception
public void clusteringOf(java.lang.String clusteredJob, java.util.List jobs) throws java.lang.Exception
clusteringOf
in interface PPS
clusteredJob
- Stringjobs
- Listjava.lang.Exception
public void endWorkflowRefinementStep(Refiner refiner) throws java.lang.Exception
endWorkflowRefinementStep
in interface PPS
refiner
- workflow Refinerjava.lang.Exception
public void isIdenticalTo(java.lang.String afterNode, java.lang.String beforeNode) throws java.lang.Exception
isIdenticalTo
in interface PPS
afterNode
- StringbeforeNode
- Stringjava.lang.Exception
public void isPartitionOf(java.lang.String afterNode, java.util.List beforeNode) throws java.lang.Exception
isPartitionOf
in interface PPS
afterNode
- StringbeforeNode
- Listjava.lang.Exception
public void registrationIntroducedFor(java.lang.String registrationNode, java.lang.String dataStagingNode) throws java.lang.Exception
registrationIntroducedFor
in interface PPS
registrationNode
- StringdataStagingNode
- Stringjava.lang.Exception
public void siteSelectionFor(java.lang.String afterNode, java.lang.String beforeNode) throws java.lang.Exception
siteSelectionFor
in interface PPS
afterNode
- StringbeforeNode
- Stringjava.lang.Exception
public void stagingIntroducedFor(java.util.List stagingNodes, java.lang.String appNode) throws java.lang.Exception
stagingIntroducedFor
in interface PPS
stagingNodes
- ListappNode
- Stringjava.lang.Exception