Skip to main content

Module stream

Module stream 

Source
Expand description

Snowflake SQL REST API source.

Executes the configured SQL statement against POST /api/v2/statements and streams the rows back as JSON. Large result sets are split server-side into partitions; the source fetches each subsequent partition via GET /api/v2/statements/{handle}?partition={n} and re-frames the rows into pages of SnowflakeSourceConfig::batch_size.

Structsยง

SnowflakeSource
A source that streams the rows of a Snowflake SQL statement via the SQL REST API.