public class CopyIntoRedshiftTableTask extends SqlTask
Task
Modifier and Type | Field and Description |
---|---|
static String |
ACTION_VAR
The ACTION variable name.
|
static String |
CDC_MERGE_SQL_VAR |
static String |
KEY_VAR
The KEY variable name.
|
static String |
MERGE_SQL_VAR |
CALLABLE_VAR, CONNECTION_ATTR, DRIVER_ATTR, SQL_ATTR, USING_ATTR
Constructor and Description |
---|
CopyIntoRedshiftTableTask() |
Modifier and Type | Method and Description |
---|---|
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. |
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.
|
String |
getTitle(Task task)
Gets the title.
|
void |
init(EtlConfig config,
Task task)
Initializes task.
|
executeBeforeEtlTask, executePreTask, getCodeLanguage, isInlineTask, isPostTask, isPreEtlTask, isPreTask
public static final String MERGE_SQL_VAR
public static final String CDC_MERGE_SQL_VAR
public static final String ACTION_VAR
public static final String KEY_VAR
public 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
executeInlineTask
in class SqlTask
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
executePostTask
in class SqlTask
config
- the etl configtask
- the task to executedataSet
- the data setscenario
- the scenarioException
- in case of any errorpublic Map<String,Object> getDefaultValues(Task task)
OnTask
getDefaultValues
in interface OnTask
getDefaultValues
in class SqlTask
task
- the taskpublic String getResourceName(Task task)
OnTask
getResourceName
in interface OnTask
getResourceName
in class SqlTask
task
- the taskpublic void init(EtlConfig config, Task task) throws Exception
OnTask
Copyright © 2010-2020 Toolsverse. All Rights Reserved.