Package | Description |
---|---|
edu.isi.pegasus.planner.refiner | |
edu.isi.pegasus.planner.transfer | |
edu.isi.pegasus.planner.transfer.refiner |
Modifier and Type | Field and Description |
---|---|
private ReplicaCatalogBridge |
MainEngine.mRCBridge
The bridge to the Replica Catalog.
|
private ReplicaCatalogBridge |
TransferEngine.mRCBridge
The bridge to the Replica Catalog.
|
Modifier and Type | Method and Description |
---|---|
void |
TransferEngine.addTransferNodes(ReplicaCatalogBridge rcb,
PlannerCache plannerCache)
Adds the transfer nodes to the workflow.
|
ADag |
DataReuseEngine.reduceWorkflow(ADag workflow,
ReplicaCatalogBridge rcb)
Reduces the workflow on the basis of the existence of lfn's in the
replica catalog.
|
Graph |
DataReuseEngine.reduceWorkflow(Graph workflow,
ReplicaCatalogBridge rcb)
Reduces the workflow on the basis of the existence of lfn's in the
replica catalog.
|
Modifier and Type | Method and Description |
---|---|
void |
Refiner.addStageOutXFERNodes(Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
void |
Refiner.addStageOutXFERNodes(Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
Modifier and Type | Field and Description |
---|---|
private ReplicaCatalogBridge |
Bundle.mRCB
The handle to the replica catalog bridge.
|
private ReplicaCatalogBridge |
BalancedCluster.mRCB
The handle to the replica catalog bridge.
|
Modifier and Type | Method and Description |
---|---|
void |
Basic.addStageOutXFERNodes(Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
void |
Empty.addStageOutXFERNodes(Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
void |
Basic.addStageOutXFERNodes(Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
void |
Bundle.addStageOutXFERNodes(Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
void |
BalancedCluster.addStageOutXFERNodes(Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
void |
Empty.addStageOutXFERNodes(Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
protected Job |
Basic.createRegistrationJob(java.lang.String regJobName,
Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb)
Creates the registration jobs, which registers the materialized files on
the output site in the Replica Catalog.
|
protected Job |
Empty.createRegistrationJob(java.lang.String regJobName,
Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb)
Creates the registration jobs, which registers the materialized files on
the output site in the Replica Catalog.
|