Skip to main content

Module stream

Module stream 

Source
Available on crate features source-redshift and source-rest only.
Expand description

Amazon Redshift query source implementation.

Redshift is PostgreSQL wire-compatible, so the source streams rows through sqlx’s Postgres cursor, re-framing them into batch_size-sized pages. It supports full and incremental replication: the incremental cursor is pushed down via a ${bookmark} bind when present and always re-checked client-side.

Structs§

RedshiftSource
A source that executes a SQL query against Amazon Redshift and returns rows as JSON objects.