edu.isi.pegasus.planner.provenance.pasoa
Interface PPS

All Known Implementing Classes:

Empty

public interface PPS

Pegasus P-assertion Support interface Classes that implement this interface assist in the creation of p-assertions for the Pegasus workflow refinement system. This interface follows a builder pattern. Using this interface proceeds as follows: 1. At the beginning of a refinement step the beginWorkflowRefinmentStep method should be called. 2. As nodes are transformed the particular refinement operation method (siteSelectionFor, isParticiationOf...) should be called. 3. When the refinement step is complete the endWorkflowStep method should be called. 4. At this point identicalTo relationships are automatically created between the resulting workflow and the input workflow A note on PHeaders: For the first refinement step, the p-header can be passed in as null. For each, subsequent refinement step the p-header provided by the endWorkflowRefinementStep method should be passed into the beginWorkflowRefinementMethod

Field Summary

static String	NAMESPACE A namespace we can use to identify relationships and concepts defined for Pegasus' provenance data
static String	PEGASUS
static String	REFINEMENT_CLUSTER
static String	REFINEMENT_REDUCE
static String	REFINEMENT_REGISTER
static String	REFINEMENT_SITE_SELECT
static String	REFINEMENT_STAGE

Method Summary

String	beginWorkflowRefinementStep(Refiner refiner, String refinementStepName, boolean firstStep)
void	clusteringOf(String clusteredJob, List jobs)
void	endWorkflowRefinementStep(Refiner refiner)
void	isIdenticalTo(String afterNode, String beforeNode)
void	isPartitionOf(String afterNode, List beforeNode)
void	registrationIntroducedFor(String registrationNode, String dataStagingNode)
void	siteSelectionFor(String afterNode, String beforeNode)
void	stagingIntroducedFor(List stagingNodes, String appNode)

Field Detail

NAMESPACE

static final String NAMESPACE

A namespace we can use to identify relationships and concepts defined for Pegasus' provenance data

See Also:

Constant Field Values

PEGASUS

static final String PEGASUS

See Also:

Constant Field Values

REFINEMENT_CLUSTER

static final String REFINEMENT_CLUSTER

See Also:

Constant Field Values

REFINEMENT_REDUCE

static final String REFINEMENT_REDUCE

See Also:

Constant Field Values

REFINEMENT_REGISTER

static final String REFINEMENT_REGISTER

See Also:

Constant Field Values

REFINEMENT_SITE_SELECT

static final String REFINEMENT_SITE_SELECT

See Also:

Constant Field Values

REFINEMENT_STAGE

static final String REFINEMENT_STAGE

See Also:

Constant Field Values

Method Detail

beginWorkflowRefinementStep

String beginWorkflowRefinementStep(Refiner refiner,
                                   String refinementStepName,
                                   boolean firstStep)
                                   throws Exception

Returns:

The ID used for the whole refinement process of this workflow

Throws:

Exception

isIdenticalTo

void isIdenticalTo(String afterNode,
                   String beforeNode)
                   throws Exception

Throws:

Exception

siteSelectionFor

void siteSelectionFor(String afterNode,
                      String beforeNode)
                      throws Exception

Throws:

Exception

stagingIntroducedFor

void stagingIntroducedFor(List stagingNodes,
                          String appNode)
                          throws Exception

Throws:

Exception

registrationIntroducedFor

void registrationIntroducedFor(String registrationNode,
                               String dataStagingNode)
                               throws Exception

Throws:

Exception

clusteringOf

void clusteringOf(String clusteredJob,
                  List jobs)
                  throws Exception

Throws:

Exception

isPartitionOf

void isPartitionOf(String afterNode,
                   List beforeNode)
                   throws Exception

Throws:

Exception

endWorkflowRefinementStep

void endWorkflowRefinementStep(Refiner refiner)
                               throws Exception

Throws:

Exception