MergeSnowflakeJournalTable 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Description¶
Triggers a merge operation on changes from journal table to a destination table in Snowflake. The merge operation is performed asynchronously and the processor polls the result of the operation. If the query is still in progress the flow file will be penalized.
Input Requirement¶
REQUIRED
Supports Sensitive Dynamic Properties¶
false
Properties¶
Property |
Description |
|---|---|
Destination Database Name |
The name of the Snowflake database where the data is being ingested to. |
Merge Query Retry Count |
Indicates how many times the merge query should be retried if it fails. |
Record Reader |
The Record Reader to use for reading the input |
Snowflake Connection Pool |
The Controller Service that is used to obtain a connection to the Snowflake database to perform merge operation. |
Relationships¶
Name |
Description |
|---|---|
ddl |
DDL to execute. |
deleted during compaction |
FlowFile deleted during compaction based on table name and generation. |
failure |
Failure query execution. |
failure retry |
Retry failure query execution. |
poll query result |
Scheduled async query execution. |
success |
Success query execution. |
unknown file type |
Unknown file type. |
Writes attributes¶
Name |
Description |
|---|---|
merge.query.id |
The ID of the query that is used to merge the journal table into the target table. |