com.toolsverse.etl.core.engine

Class TaskExecutor

Object

com.toolsverse.etl.core.engine.TaskExecutor

public class TaskExecutor
extends Object

This class executes all tasks attached to the Source or Destination.

Since:

1.0

Version:

2.0

Constructor Summary

Constructors

Constructor and Description
TaskExecutor(TransactionMonitor transactionMonitor)

Method Summary

Modifier and Type	Method and Description
TaskResult	executeBeforeEtlTasks(EtlConfig config, Block block, Scenario scenario) Executes PRE ETL tasks for the Block if any exist.
TaskResult	executeInlineTasks(EtlConfig config, Block block, Scenario scenario, long index) Executes INLINE tasks for the Block if any exist.
TaskResult	executeOnExceptionTasks(EtlConfig config, Block block, Scenario scenario, DataSet dataSet) Executes ON_EXCEPTION tasks for the Block if any exist.
TaskResult	executePostTasks(EtlConfig config, Block block, Scenario scenario, DataSet dataSet) Executes POST tasks for the Block if any exist.
TaskResult	executePreTasks(EtlConfig config, Block block, Scenario scenario, DataSet dataSet) Executes PRE tasks for the Block if any exist.

Methods inherited from class Object

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

Constructor Detail

TaskExecutor

public TaskExecutor(TransactionMonitor transactionMonitor)

Method Detail

executeBeforeEtlTasks

public TaskResult executeBeforeEtlTasks(EtlConfig config,
                                        Block block,
                                        Scenario scenario)
                                 throws Exception

Executes PRE ETL tasks for the Block if any exist. Block can be either Source or Destination. PRE ETL tasks usually run for the Source after extract SQL is executed and meta data populated but before actual extract starts.

Parameters:

config - The config

block - The block

scenario - The scenario

Returns:

the task result

Throws:

Exception - in case of any error

executeInlineTasks

public TaskResult executeInlineTasks(EtlConfig config,
                                     Block block,
                                     Scenario scenario,
                                     long index)
                              throws Exception

Executes INLINE tasks for the Block if any exist. Block can be either Source or Destination. INLINE tasks run for each record of the data set.

Parameters:

config - The config

block - The block

scenario - The scenario

index - The index of the record

Returns:

the task result

Throws:

Exception - in case of any error

executeOnExceptionTasks

public TaskResult executeOnExceptionTasks(EtlConfig config,
                                          Block block,
                                          Scenario scenario,
                                          DataSet dataSet)
                                   throws Exception

Executes ON_EXCEPTION tasks for the Block if any exist. Block can be either Source or Destination. ON_EXCEPTION tasks run after everything associated with the block said and done and there is an Exception.

Parameters:

config - The config

block - The block

scenario - The scenario

dataSet - the data set

Returns:

the task result

Throws:

Exception - in case of any error

executePostTasks

public TaskResult executePostTasks(EtlConfig config,
                                   Block block,
                                   Scenario scenario,
                                   DataSet dataSet)
                            throws Exception

Executes POST tasks for the Block if any exist. Block can be either Source or Destination. POST tasks run after everything associated with the block said and done. Example: after extract or after load.

Parameters:

config - The config

block - The block

scenario - The scenario

dataSet - the data set

Returns:

the task result

Throws:

Exception - in case of any error

executePreTasks

public TaskResult executePreTasks(EtlConfig config,
                                  Block block,
                                  Scenario scenario,
                                  DataSet dataSet)
                           throws Exception

Executes PRE tasks for the Block if any exist. Block can be either Source or Destination. PRE tasks run just before any actions associated with the block are taken. Example: before extract or before load.

Parameters:

config - The config

block - The block

scenario - The scenario

dataSet - the data set

Returns:

the task result

Throws:

Exception - in case of any error