Package org.epics.archiverappliance.etl

Class ETLExecutor

java.lang.Object

org.epics.archiverappliance.etl.ETLExecutor

public class ETLExecutor
extends Object

Run ETLs for one PV; mostly for unit tests..

Author:

luofeng

Constructor Summary

Constructors

Constructor	Description
ETLExecutor()

Method Summary

Modifier and Type	Method	Description
static void	moveDataFromOneStorageToAnother(ConfigService configService, String pvName, String storageName, String destStr)	Run ETL for one PV until one storage; used in consolidate...
static void	runETLs(ConfigService configService, Instant timeETLruns)	This should only be called from within unit tests...
static void	runPvETLsBeforeOneStorage(ConfigService configService, Instant timeETLRuns, String pvName, String storageName)	Run ETL for one PV until one storage; used in consolidate...

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ETLExecutor

public ETLExecutor()

Method Details

runETLs

public static void runETLs(ConfigService configService,
 Instant timeETLruns)
                    throws IOException

This should only be called from within unit tests...

Parameters:

configService - ConfigService

timeETLruns - Instant

Throws:

IOException -  

runPvETLsBeforeOneStorage

public static void runPvETLsBeforeOneStorage(ConfigService configService,
 Instant 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 - Instant

pvName - The name of PV.

storageName -  

Throws:

IOException -  

moveDataFromOneStorageToAnother

public static void moveDataFromOneStorageToAnother(ConfigService configService,
 String pvName,
 String storageName,
 String destStr)
                                            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

pvName - The name of PV.

storageName -  

Throws:

IOException -