Class ETLExecutor


  • public class ETLExecutor
    extends Object
    Run ETLs for one PV; mostly for unit tests..
    Author:
    luofeng
    • Constructor Detail

      • ETLExecutor

        public ETLExecutor()
    • Method Detail

      • runETLs

        public static void runETLs​(ConfigService configService,
                                   Timestamp timeETLruns)
                            throws IOException
        This should only be called from within unit tests...
        Parameters:
        configService - ConfigService
        timeETLruns - Timestamp
        Throws:
        IOException -  
      • runPvETLsBeforeOneStorage

        public static void runPvETLsBeforeOneStorage​(ConfigService configService,
                                                     Timestamp timeETLruns,
                                                     String pvName,
                                                     String storageName)
                                              throws IOException
        Run ETL for one PV until one storage; used in consolidate... Make sure that the regular ETL has been paused..
        Parameters:
        configService - ConfigService
        timeETLruns - Timestamp
        pvName - The name of PV.
        storageName -  
        Throws:
        IOException -