UpdateSnowflakeStream 2025.10.2.19¶

Bundle¶

com.snowflake.openflow.runtime | runtime-snowflake-processors-nar

Description¶

Manages Snowflake streams by creating, dropping, or replacing them based on the configured operation. Streams in Snowflake capture data change for tables and can be used to track DML changes over time.

Tags¶

cdc, create, drop, preview, replace, snowflake, stream, table

Input Requirement¶

REQUIRED

Supports Sensitive Dynamic Properties¶

false

Properties¶

Property	Description
Connection Pool	The connection pool to use to connect to Snowflake
Object Identifier Resolution	Controls how source object identifiers (schemas, tables, columns) are stored and queried in Snowflake. This setting determines whether you will need to use double quotes in your SQL queries.
Schema Name	The name of the schema containing the stream and/or source table
Source Table Name	The name of the source table for the stream
Stream Creation Parameters	Additional parameters to include in the CREATE STREAM statement. For example, ‘APPEND_ONLY=TRUE SHOW_INITIAL_ROWS=TRUE’
Stream Name	The name of the stream to create, drop, or replace
Update Type	The type of stream operation to perform

Relationships¶

Name	Description
failure	The incoming FlowFile is routed to this relationship if the stream operation cannot be completed
object not found	The incoming FlowFile is routed to this relationship if the specified stream or source table does not exist.
success	The incoming FlowFile is routed to this relationship after the stream operation has been completed successfully