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.

Tags¶

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.