Snowflake Processor

Snowflake is a cloud-based data warehouse system. The user can use Snowflake as a processor in Gathr for ELT pipelines.

Processor Configuration #

Connection Name: Connections are the service identifiers. A connection name can be selected from the list if you have created and saved connection details for Snowflake earlier. Or create one as explained in the topic - Snowflake Connection →

Warehouse Name: The warehouse name should be specified.

Schema Name: The schema name should be specified.

Query Type: Select the type of query out of these options: Static query or Dynamic query.

Query: It will be required to specify whether static value/dynamic value was selected in the query type.

Static query contains normal SQL query while as in dynamic query you can use existing dataset columns using @.

Dynamic query example:

update emp_basic set first_name='@{column.JDBC_24307.NAME}' where first_name='john'