com.toolsverse.etl.core.task.snowflake

Class CopyIntoTableTask

Object

com.toolsverse.etl.core.task.common.SqlTask

com.toolsverse.etl.core.task.snowflake.CopyIntoTableTask

All Implemented Interfaces:

OnTask, SupportsCodeUpdate, SupportsRecording

public class CopyIntoTableTask
extends SqlTask

This is Task.PRE and Task.POST task which loads data into snowflake database from the file.

Since:

5.0

Version:

1.0

See Also:

Task

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTION_VAR The ACTION variable name.
static String	CDC_MERGE_ALTERNATIVE_VAR
static String	CDC_MERGE_SQL_VAR
static String	CDC_MERGE_WITH_DELETE_VAR
static String	KEY_VAR The KEY variable name.
static String	MERGE_SQL_VAR
static String	STAGE_VAR
static String	USE_SELECT_VAR The USE_SELECT variable.
static String	USE_STAGING_VAR The USE_STAGING_VAR.

Fields inherited from class com.toolsverse.etl.core.task.common.SqlTask

CALLABLE_VAR, CONNECTION_ATTR, DRIVER_ATTR, SQL_ATTR, USING_ATTR

Constructor Summary

Constructors

Constructor and Description
CopyIntoTableTask()

Method Summary

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.

Methods inherited from class com.toolsverse.etl.core.task.common.SqlTask

executeBeforeEtlTask, executePreTask, getCodeLanguage, isInlineTask, isPostTask, isPreEtlTask, isPreTask

Methods inherited from class Object

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

Field Detail

STAGE_VAR

public static final String STAGE_VAR

See Also:

Constant Field Values

MERGE_SQL_VAR

public static final String MERGE_SQL_VAR

See Also:

Constant Field Values

CDC_MERGE_SQL_VAR

public static final String CDC_MERGE_SQL_VAR

See Also:

Constant Field Values

CDC_MERGE_ALTERNATIVE_VAR

public static final String CDC_MERGE_ALTERNATIVE_VAR

See Also:

Constant Field Values

CDC_MERGE_WITH_DELETE_VAR

public static final String CDC_MERGE_WITH_DELETE_VAR

See Also:

Constant Field Values

ACTION_VAR

public static final String ACTION_VAR

The ACTION variable name.

See Also:

Constant Field Values

KEY_VAR

public static final String KEY_VAR

The KEY variable name.

See Also:

Constant Field Values

USE_SELECT_VAR

public static final String USE_SELECT_VAR

The USE_SELECT variable.

See Also:

Constant Field Values

USE_STAGING_VAR

public static final String USE_STAGING_VAR

The USE_STAGING_VAR.

See Also:

Constant Field Values

Constructor Detail

CopyIntoTableTask

public CopyIntoTableTask()

Method Detail

executeInlineTask

public TaskResult executeInlineTask(EtlConfig config,
                                    Task task,
                                    long index,
                                    Scenario scenario)
                             throws Exception

Description copied from interface: OnTask

Executes task for each row of the data set.

Specified by:

executeInlineTask in interface OnTask

Overrides:

executeInlineTask in class SqlTask

Parameters:

config - the etl config

task - the task to execute

index - the current row number

scenario - the scenario

Returns:

the task result

Throws:

Exception - in case of any error

executePostTask

public TaskResult executePostTask(EtlConfig config,
                                  Task task,
                                  DataSet dataSet,
                                  Scenario scenario)
                           throws Exception

Description copied from interface: OnTask

Executes task after extract or load finished.

Specified by:

executePostTask in interface OnTask

Overrides:

executePostTask in class SqlTask

Parameters:

config - the etl config

task - the task to execute

dataSet - the data set

scenario - the scenario

Returns:

the task result

Throws:

Exception - in case of any error

getDefaultValues

public Map<String,Object> getDefaultValues(Task task)

Description copied from interface: OnTask

Gets the default values for the model used to edit task.

Specified by:

getDefaultValues in interface OnTask

Overrides:

getDefaultValues in class SqlTask

Parameters:

task - the task

Returns:

the default values

getResourceName

public String getResourceName(Task task)

Description copied from interface: OnTask

Gets the name of the xml file used to create a model for the task editor.

Specified by:

getResourceName in interface OnTask

Overrides:

getResourceName in class SqlTask

Parameters:

task - the task

Returns:

the resource name

init

public void init(EtlConfig config,
                 Task task)
          throws Exception

Description copied from interface: OnTask

Initializes task.

Specified by:

init in interface OnTask

Overrides:

init in class SqlTask

Parameters:

config - the etl config

task - the task to initialize

Throws:

Exception - in case of any error

getTitle

public String getTitle(Task task)

Description copied from interface: OnTask

Gets the title.

Specified by:

getTitle in interface OnTask

Overrides:

getTitle in class SqlTask

Parameters:

task - the task

Returns:

the title