public class JobAggregatorInstanceFactory
extends java.lang.Object
JobAggregatorFactory
Modifier and Type | Field and Description |
---|---|
private PegasusBag |
mBag
The bag of initialization objects
|
private ADag |
mDAG
ADag object containing the jobs that have been scheduled by the site
selector.
|
private static java.util.Map |
mImplementingClassNameTable
A table that maps, Pegasus style keys to the names of the corresponding classes
implementing the CondorStyle interface.
|
private java.util.Map |
mImplementingClassTable
A table that maps, Pegasus style keys to appropriate classes implementing the
JobAggregator interface
|
private boolean |
mInitialized
A boolean indicating that the factory has been initialized.
|
protected PegasusProperties |
mProps
The handle to the properties object holding all the properties.
|
Constructor and Description |
---|
JobAggregatorInstanceFactory()
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
private java.lang.Object |
get(java.lang.String style)
Returns the implementation from the implementing class table.
|
private static java.util.Map |
implementingClassNameTable()
Returns a table that maps, the Pegasus style keys to the names of implementing
classes.
|
void |
initialize(ADag dag,
PegasusBag bag)
Initializes the Factory.
|
JobAggregator |
loadInstance(Job job)
Returns the appropriate handle to the JobAggregator that is to be used
for a particular type of job.
|
private void |
put(java.lang.String style,
java.lang.Object implementation)
Inserts an entry into the implementing class table.
|
private static java.util.Map mImplementingClassNameTable
private java.util.Map mImplementingClassTable
protected PegasusProperties mProps
private ADag mDAG
private boolean mInitialized
private PegasusBag mBag
public JobAggregatorInstanceFactory()
public void initialize(ADag dag, PegasusBag bag) throws JobAggregatorFactoryException
dag
- the workflow that is being clustered.bag
- the bag of initialization objects.JobAggregatorFactoryException
- that nests any error that
might occur during the instantiation of the implementation.public JobAggregator loadInstance(Job job) throws JobAggregatorFactoryException
job
- the job corresponding to which the aggregator is to be
loaded.JobAggregatorFactoryException
- that nests any error that
might occur during the instantiationprivate java.lang.Object get(java.lang.String style)
style
- the aggregator styleprivate void put(java.lang.String style, java.lang.Object implementation)
style
- the aggregator styleimplementation
- the class implementing that aggregator.private static java.util.Map implementingClassNameTable()