SnowflakeNodeData
¶
Source code in docs_src/capo_glue/types/snowflake_node_data.py
action
instance-attribute
¶
action: NotRequired[GenericString]
Specifies what action to take when writing to a table with preexisting data. Valid values: append, merge, truncate, drop.
additional_options
instance-attribute
¶
additional_options: NotRequired[AdditionalOptions]
Specifies additional options passed to the Snowflake connector. If options are specified elsewhere in this node, this will take precedence.
auto_pushdown
instance-attribute
¶
auto_pushdown: BooleanValue
Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves performance of some queries.
connection
instance-attribute
¶
connection: NotRequired[Option]
Specifies a Glue Data Catalog Connection to a Snowflake endpoint.
database
instance-attribute
¶
database: NotRequired[GenericString]
Specifies a Snowflake database for your node to use.
merge_action
instance-attribute
¶
merge_action: NotRequired[GenericLimitedString]
Specifies a merge action. Valid values: simple, custom. If simple, merge behavior is defined by MergeWhenMatched and MergeWhenNotMatched. If custom, defined by MergeClause.
merge_clause
instance-attribute
¶
merge_clause: NotRequired[GenericString]
A SQL statement that specifies a custom merge behavior.
merge_when_matched
instance-attribute
¶
merge_when_matched: NotRequired[GenericLimitedString]
Specifies how to resolve records that match preexisting data when merging. Valid values: update, delete.
merge_when_not_matched
instance-attribute
¶
merge_when_not_matched: NotRequired[GenericLimitedString]
Specifies how to process records that do not match preexisting data when merging. Valid values: insert, none.
post_action
instance-attribute
¶
post_action: NotRequired[GenericString]
A SQL string run after the Snowflake connector performs its standard actions.
pre_action
instance-attribute
¶
pre_action: NotRequired[GenericString]
A SQL string run before the Snowflake connector performs its standard actions.
sample_query
instance-attribute
¶
sample_query: NotRequired[GenericString]
A SQL string used to retrieve data with the query sourcetype.
schema
instance-attribute
¶
schema: NotRequired[GenericString]
Specifies a Snowflake database schema for your node to use.
selected_columns
instance-attribute
¶
selected_columns: NotRequired[OptionList]
Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list of structures with value, label and description keys. Each structure describes a column.
source_type
instance-attribute
¶
source_type: NotRequired[GenericLimitedString]
Specifies how retrieved data is specified. Valid values: "table", "query".
staging_table
instance-attribute
¶
staging_table: NotRequired[GenericString]
The name of a staging table used when performing merge or upsert append actions. Data is written to this table, then moved to table by a generated postaction.
table
instance-attribute
¶
table: NotRequired[GenericString]
Specifies a Snowflake table for your node to use.
table_schema
instance-attribute
¶
table_schema: NotRequired[OptionList]
Manually defines the target schema for the node. A list of structures with value , label and description keys. Each structure defines a column.
upsert
instance-attribute
¶
upsert: BooleanValue
Used when Action is append. Specifies the resolution behavior when a row already exists. If true, preexisting rows will be updated. If false, those rows will be inserted.