Class DAXReplicaStore

  • All Implemented Interfaces:
    CodeGenerator

    public class DAXReplicaStore
    extends java.lang.Object
    implements CodeGenerator
    A generator that writes out the replica store containing a file based replica catalog that has the file locations mentioned in the DAX.
    Version:
    $Revision$
    Author:
    Karan Vahi
    • Field Detail

      • DAX_REPLICA_STORE_CATALOG_KEY

        public static final java.lang.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
        See Also:
        Constant Field Values
      • DAX_REPLICA_STORE_CATALOG_IMPLEMENTER

        public static final java.lang.String DAX_REPLICA_STORE_CATALOG_IMPLEMENTER
        The name of the Replica Catalog Implementer that serves as the source for cache files.
        See Also:
        Constant Field Values
      • CACHE_FILE_SUFFIX

        private static final java.lang.String CACHE_FILE_SUFFIX
        Suffix to be applied for cache file generation.
        See Also:
        Constant Field Values
      • DAX_REPLICA_STORE_SUFFIX

        private static final java.lang.String DAX_REPLICA_STORE_SUFFIX
        Suffix to be applied for the DAX Replica Store.
        See Also:
        Constant Field Values
      • mBag

        protected PegasusBag mBag
        The bag of initialization objects.
      • mSubmitFileDir

        protected java.lang.String mSubmitFileDir
        The directory where all the submit files are to be generated.
      • mProps

        protected PegasusProperties mProps
        The object holding all the properties pertaining to Pegasus.
      • mPOptions

        protected PlannerOptions mPOptions
        The object containing the command line options specified to the planner at runtime.
      • mLogger

        protected LogManager mLogger
        The handle to the logging object.
    • Constructor Detail

      • DAXReplicaStore

        public DAXReplicaStore()
    • Method Detail

      • getDAXReplicaStoreFile

        public static java.lang.String getDAXReplicaStoreFile​(PlannerOptions options,
                                                              java.lang.String label,
                                                              java.lang.String index)
        Returns the path to the DAX Replica Store File.
        Parameters:
        options - the options for the sub workflow.
        label - the label for the workflow.
        index - the index for the workflow.
        Returns:
        the name of the cache file
      • generateCode

        public java.util.Collection<java.io.File> generateCode​(ADag dag)
                                                        throws CodeGeneratorException
        Generates the notifications input file. The method initially generates work-flow level notification records, followed by job-level notification records.
        Specified by:
        generateCode in interface CodeGenerator
        Parameters:
        dag - the concrete work-flow.
        Returns:
        the Collection of File objects for the files written out.
        Throws:
        CodeGeneratorException - in case of any error occurring code generation.
      • startMonitoring

        public boolean startMonitoring()
        Not implemented
        Specified by:
        startMonitoring in interface CodeGenerator
        Returns:
        boolean indicating whether could successfully start the monitor daemon or not.