public class TaskExecutor
extends Object
Source
or
Destination
.Constructor and Description |
---|
TaskExecutor(TransactionMonitor transactionMonitor) |
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. |
public TaskExecutor(TransactionMonitor transactionMonitor)
public TaskResult executeBeforeEtlTasks(EtlConfig config, Block block, Scenario scenario) throws Exception
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.config
- The configblock
- The blockscenario
- The scenarioException
- in case of any errorpublic TaskResult executeInlineTasks(EtlConfig config, Block block, Scenario scenario, long index) throws Exception
Block
if any exist.
Block
can be either Source
or
Destination
. INLINE tasks run for each record of the data
set.config
- The configblock
- The blockscenario
- The scenarioindex
- The index of the recordException
- in case of any errorpublic TaskResult executeOnExceptionTasks(EtlConfig config, Block block, Scenario scenario, DataSet dataSet) throws Exception
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.config
- The configblock
- The blockscenario
- The scenariodataSet
- the data setException
- in case of any errorpublic TaskResult executePostTasks(EtlConfig config, Block block, Scenario scenario, DataSet dataSet) throws Exception
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.config
- The configblock
- The blockscenario
- The scenariodataSet
- the data setException
- in case of any errorpublic TaskResult executePreTasks(EtlConfig config, Block block, Scenario scenario, DataSet dataSet) throws Exception
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.config
- The configblock
- The blockscenario
- The scenariodataSet
- the data setException
- in case of any errorCopyright © 2010-2020 Toolsverse. All Rights Reserved.