edu.isi.pegasus.planner.code.generator
public class DAXReplicaStore extends Object implements CodeGenerator
Modifier and Type | Field and Description |
---|---|
private static String |
CACHE_FILE_SUFFIX
Suffix to be applied for cache file generation.
|
static String |
DAX_REPLICA_STORE_CATALOG_IMPLEMENTER
The name of the Replica Catalog Implementer that serves as the source for
cache files.
|
static String |
DAX_REPLICA_STORE_CATALOG_KEY
The name of the source key for Replica Catalog Implementer that serves as
the repository for DAX Replica Store
|
private static String |
DAX_REPLICA_STORE_SUFFIX
Suffix to be applied for the DAX Replica Store.
|
protected PegasusBag |
mBag
The bag of initialization objects.
|
protected LogManager |
mLogger
The handle to the logging object.
|
protected PlannerOptions |
mPOptions
The object containing the command line options specified to the planner
at runtime.
|
protected PegasusProperties |
mProps
The object holding all the properties pertaining to Pegasus.
|
protected String |
mSubmitFileDir
The directory where all the submit files are to be generated.
|
VERSION
Constructor and Description |
---|
DAXReplicaStore() |
Modifier and Type | Method and Description |
---|---|
Collection<File> |
generateCode(ADag dag)
Generates the notifications input file.
|
void |
generateCode(ADag dag,
Job job)
Not implemented
|
static String |
getDAXReplicaStoreFile(PlannerOptions options,
String label,
String index)
Returns the path to the DAX Replica Store File.
|
void |
initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
reset()
Not implemented
|
boolean |
startMonitoring()
Not implemented
|
public static final String DAX_REPLICA_STORE_CATALOG_KEY
public static final String DAX_REPLICA_STORE_CATALOG_IMPLEMENTER
private static final String CACHE_FILE_SUFFIX
private static final String DAX_REPLICA_STORE_SUFFIX
protected PegasusBag mBag
protected String mSubmitFileDir
protected PegasusProperties mProps
protected PlannerOptions mPOptions
protected LogManager mLogger
public static String getDAXReplicaStoreFile(PlannerOptions options, String label, String index)
options
- the options for the sub workflow.label
- the label for the workflow.index
- the index for the workflow.public void initialize(PegasusBag bag) throws CodeGeneratorException
initialize
in interface CodeGenerator
bag
- the bag of initialization objects.CodeGeneratorException
- in case of any error occurring code generation.public Collection<File> generateCode(ADag dag) throws CodeGeneratorException
generateCode
in interface CodeGenerator
dag
- the concrete work-flow.File
objects for the files written
out.CodeGeneratorException
- in case of any error occurring code generation.public void generateCode(ADag dag, Job job) throws CodeGeneratorException
generateCode
in interface CodeGenerator
dag
- the work-flowjob
- the job for which the code is to be generated.CodeGeneratorException
public boolean startMonitoring()
startMonitoring
in interface CodeGenerator
public void reset() throws CodeGeneratorException
reset
in interface CodeGenerator
CodeGeneratorException
- in case of any error occuring code generation.