Modifier and Type | Field and Description |
---|---|
static String |
DESCRIPTION
A short description about the partitioner.
|
mClusteredRelations, mJobAggregatorFactory, mLogger, mPartitionClusterMap, mProps, mScheduledDAG, mSubInfoMap
Constructor and Description |
---|
Vertical()
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
protected String |
constructClusteredJobID(Partition partition)
Returns the ID for the clustered job corresponding to a partition.
|
String |
description()
Returns a textual description of the transfer implementation.
|
void |
determineInputOutputFiles(AggregatedJob job)
Determine the input and output files of the job on the basis of the
order of the constituent jobs in the AggregatedJob.
|
protected String |
getLogicalNameForJobs(List<Job> jobs)
Returns null as for label based clustering we dont want the transformation
name to be considered for constructing the name of the clustered jobs
|
List |
order(Partition p)
Returns the nodes in the partition as a List in the topologically sorted
order.
|
addJob, associate, clusteredJob, clusteredJob, determineClusters, getClusteredDAG, getJob, initialize, parents
public static final String DESCRIPTION
public String description()
public List order(Partition p) throws ClustererException
order
in class Abstract
p
- the partition whose nodes have to be ordered.String
objects that are the ID's
of the nodes.ClustererException
- in case of error.public void determineInputOutputFiles(AggregatedJob job)
determineInputOutputFiles
in class Abstract
job
- the AggregatedJob
ClustererException
- in case of error.protected String getLogicalNameForJobs(List<Job> jobs)
getLogicalNameForJobs
in class Abstract
jobs
- List of jobsprotected String constructClusteredJobID(Partition partition)
constructClusteredJobID
in class Abstract
partition
- the partition.Copyright © 2011 The University of Southern California. All Rights Reserved.