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