Package | Description |
---|---|
edu.isi.pegasus.planner.cluster | |
edu.isi.pegasus.planner.parser | |
edu.isi.pegasus.planner.parser.pdax | |
edu.isi.pegasus.planner.partitioner |
Modifier and Type | Method and Description |
---|---|
protected void |
Abstract.associate(Partition p,
Job job)
Maps the partition to the corresponding clustered job.
|
protected Job |
Abstract.clusteredJob(Partition p)
Returns the job corresponding to a partition.
|
protected java.lang.String |
Vertical.constructClusteredJobID(Partition partition)
Returns the ID for the clustered job corresponding to a partition.
|
protected java.lang.String |
Abstract.constructClusteredJobID(Partition partition)
Returns the ID for the clustered job corresponding to a partition.
|
void |
Clusterer.determineClusters(Partition partition)
Determine the clusters for a partition.
|
void |
Horizontal.determineClusters(Partition partition)
Determine the clusters for a partition.
|
void |
Abstract.determineClusters(Partition partition)
It creates a single clustered job for the partition.
|
java.util.List |
Vertical.order(Partition p)
Returns the nodes in the partition as a List in the topologically sorted
order.
|
abstract java.util.List<java.lang.String> |
Abstract.order(Partition p)
Returns the nodes in the partition as a List in a particular order.
|
Modifier and Type | Field and Description |
---|---|
private Partition |
PDAXParser.mPartition
The object holding the contents of one partition as indicated in the
pdax.
|
Modifier and Type | Method and Description |
---|---|
void |
Callback.cbPartition(Partition partition)
Callback for the partition .
|
void |
PDAX2MDAG.cbPartition(Partition partition)
Callback for the partition .
|
protected Job |
PDAX2MDAG.constructDAGJob(Partition partition,
java.io.File directory,
java.lang.String dax)
Constructs a job that plans and submits the partitioned workflow,
referred to by a Partition.
|
protected java.lang.String |
PDAX2MDAG.getAbsolutePath(Partition partition,
java.lang.String directory,
java.lang.String suffix)
Returns the absolute path to a dagman (usually) related file for a
particular partition in the submit directory that is passed as an input
parameter.
|
protected java.lang.String |
PDAX2MDAG.getBaseName(Partition partition)
Returns the base name of the submit directory in which the submit files
for a particular partition reside.
|
protected java.lang.String |
PDAX2MDAG.getBasename(Partition partition,
java.lang.String suffix)
Returns the basename of a dagman (usually) related file for a particular
partition.
|
protected java.lang.String |
PDAX2MDAG.writeOutBraindump(java.io.File directory,
Partition partition,
java.lang.String dax,
java.lang.String dag)
Writes out the braindump.txt file for a partition in the partition submit
directory.
|
Modifier and Type | Field and Description |
---|---|
private Partition |
Topological.mPartition
The partition that has to be sorted.
|
Modifier and Type | Method and Description |
---|---|
protected Partition |
Horizontal.createPartition(java.util.List nodes)
Creates a partition out of a list of nodes.
|
Modifier and Type | Method and Description |
---|---|
void |
WriterCallback.cbPartition(Partition p)
Callback for when a partitioner determines that partition has been
constructed.
|
void |
Callback.cbPartition(Partition partition)
Callback for when a partitioner determines that partition has been
constructed.
|
void |
ClustererCallback.cbPartition(Partition p)
Callback for when a partitioner determines that partition has been
constructed.
|
void |
PDAXWriter.write(Partition p)
Writes out a partition to the associate XML stream.
|
boolean |
DAXWriter.writePartitionDax(Partition partition)
It writes out a dax consisting of the jobs as specified in the partition.
|
boolean |
MultipleLook.writePartitionDax(Partition partition,
int index)
It writes out a dax consisting of the jobs as specified in the partition.
|
abstract boolean |
DAXWriter.writePartitionDax(Partition partition,
int index)
It writes out a dax consisting of the jobs as specified in the partition.
|
boolean |
SingleLook.writePartitionDax(Partition partition,
int index)
It writes out a dax consisting of the jobs as specified in the partition.
|
Constructor and Description |
---|
Topological(Partition p)
The overloaded constructor.
|