public class SplitDataSet extends Object implements OnTask, TaskFeatureProvider, SupportsRecording
Task.POST
task splits data set using either combination of keys
(group by) or maximum number of records.Task
Constructor and Description |
---|
SplitDataSet() |
Modifier and Type | Method and Description |
---|---|
TaskResult |
executeBeforeEtlTask(EtlConfig config,
Task action,
Scenario scenario)
Executes
task before etl process is started. |
TaskResult |
executeInlineTask(EtlConfig config,
Task task,
long index,
Scenario scenario)
Executes
task for each row of the data set. |
TaskResult |
executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario)
Executes
task after extract or load finished. |
TaskResult |
executePreTask(EtlConfig config,
Task task,
Scenario scenario)
Executes
task before extract or load started. |
String |
getCodeLanguage(Task task)
Gets the code language.
|
Map<String,Object> |
getDefaultValues(Task task)
Gets the default values for the model used to edit task.
|
String |
getResourceName(Task task)
Gets the name of the xml file used to create a model for the task editor.
|
TaskFeature |
getTaskFeature()
Gets the task feature.
|
String |
getTitle(Task task)
Gets the title.
|
void |
init(EtlConfig config,
Task task)
Initializes task.
|
boolean |
isInlineTask()
Checks if this is inline task.
|
boolean |
isPostTask()
Checks if it is a post task.
|
boolean |
isPreEtlTask()
Checks if it is a pre etl task.
|
boolean |
isPreTask()
Checks if it is a pre task.
|
public TaskResult executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario) throws Exception
OnTask
task
before etl process is started.executeBeforeEtlTask
in interface OnTask
config
- the etl configaction
- the task to executescenario
- the scenarioException
- in case of any errorpublic TaskResult executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario) throws Exception
OnTask
task
for each row of the data set.executeInlineTask
in interface OnTask
config
- the etl configtask
- the task to executeindex
- the current row numberscenario
- the scenarioException
- in case of any errorpublic TaskResult executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario) throws Exception
OnTask
task
after extract or load finished.executePostTask
in interface OnTask
config
- the etl configtask
- the task to executedataSet
- the data setscenario
- the scenarioException
- in case of any errorpublic TaskResult executePreTask(EtlConfig config, Task task, Scenario scenario) throws Exception
OnTask
task
before extract or load started.executePreTask
in interface OnTask
config
- the etl configtask
- the task to executescenario
- the scenarioException
- in case of any errorpublic Map<String,Object> getDefaultValues(Task task)
OnTask
getDefaultValues
in interface OnTask
task
- the taskpublic String getResourceName(Task task)
OnTask
getResourceName
in interface OnTask
task
- the taskpublic TaskFeature getTaskFeature()
TaskFeatureProvider
getTaskFeature
in interface TaskFeatureProvider
public void init(EtlConfig config, Task task) throws Exception
OnTask
public boolean isInlineTask()
OnTask
isInlineTask
in interface OnTask
public boolean isPostTask()
OnTask
isPostTask
in interface OnTask
public boolean isPreEtlTask()
OnTask
isPreEtlTask
in interface OnTask
public boolean isPreTask()
OnTask
public String getTitle(Task task)
OnTask
public String getCodeLanguage(Task task)
OnTask
getCodeLanguage
in interface OnTask
task
- the taskCopyright © 2010-2020 Toolsverse. All Rights Reserved.