com.toolsverse.etl.core.engine

Class EtlProcess

Object

com.toolsverse.etl.core.engine.EtlProcess

public class EtlProcess
extends Object

This class executes one or multiple etl scenarios. Reads configuration file if needed.

Since:

1.0

Version:

2.0

See Also:

Scenario, Extractor, Loader

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EtlProcess.EtlMode The EtlProcess modes INCLUDED - ETL engine included into other Toolsverse apps, such as Data Explorer STANDALONE - ETL engine is a standalone application EMBEDDED - ETL engine embedded into third-party application.

Constructor Summary

Constructors

Constructor and Description
EtlProcess(EtlProcess.EtlMode mode) Instantiates a new etl process.

Method Summary

Modifier and Type	Method and Description
EtlResponse	execute() Executes etl process.
EtlResponse	execute(EtlConfig config) Executes process using given etl config.
EtlResponse	execute(EtlRequest request) Executes process using given etl request.
void	execute(Scenario scenario, EtlConfig config, int index, TransactionMonitor transactionMonitor) Executes etl scenario.
List<DataSetConnector<?,?>>	getConnectors() Gets connectors.
List<Driver>	getDrivers() Gets drivers.
boolean	isInitialized() Checks if process is initialized.
static void	main(String[] args) Reads etl config from the file and executes one or multiple scenarios if any configured.
void	printConfig(EtlConfig etlConfig) Prints the config.
void	update() Updates software.

Methods inherited from class Object

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

Constructor Detail

EtlProcess

public EtlProcess(EtlProcess.EtlMode mode)

Instantiates a new etl process.

Parameters:

mode - the mode. The standalone mode implies executing main(...)

Method Detail

main

public static void main(String[] args)

Reads etl config from the file and executes one or multiple scenarios if any configured.

Parameters:

args - String[]

getDrivers

public List<Driver> getDrivers()

Gets drivers.

Returns:

the list of drivers

getConnectors

public List<DataSetConnector<?,?>> getConnectors()

Gets connectors.

Returns:

the list of connectors

execute

public EtlResponse execute()

Executes etl process.

Returns:

the etl response

execute

public EtlResponse execute(EtlConfig config)

Executes process using given etl config.

Parameters:

config - the etl config

Returns:

the etl response

execute

public EtlResponse execute(EtlRequest request)

Executes process using given etl request.

Parameters:

request - the etl request

Returns:

the etl response

execute

public void execute(Scenario scenario,
                    EtlConfig config,
                    int index,
                    TransactionMonitor transactionMonitor)
             throws Exception

Executes etl scenario.

Parameters:

scenario - the scenario

config - the etl config

index - the scenario index. -1 if it is a main scenario.

transactionMonitor - the transaction monitor

Throws:

Exception - in case of any error

isInitialized

public boolean isInitialized()

Checks if process is initialized.

Returns:

true, if process initialized

printConfig

public void printConfig(EtlConfig etlConfig)

Prints the config.

Parameters:

etlConfig - the etl config

update

public void update()

Updates software.