Skip to main content
The Stream Input transformation component reads selected columns from a Snowflake stream, and makes those columns available to the pipeline. The stream must already exist in Snowflake. If necessary, you can create a new stream in Snowflake using the Create Stream component. For more information on Snowflake streams, read Introduction to Streams in the Snowflake documentation.

​
Use case

A Snowflake stream object records row-level changes made to tables, including inserts, updates, and deletes, as well as metadata about each change. Using Stream Input, you can ingest these change records into your pipeline and take further actions based on the change data.

​
Properties

​
string
required
A human-readable name for the component.
​
drop-down
required
The Snowflake database. The special value [Environment Default] uses the database defined in the environment. Read Databases, Tables and Views - Overview to learn more.
​
drop-down
required
The Snowflake schema. The special value [Environment Default] uses the schema defined in the environment. Read Database, Schema, and Share DDL to learn more.
​
string
required
Enter the name of the stream that you want to take data from.
​
object selector
required
Select columns to read from the stream.