risingwave_stream::executor::backfill::cdc::upstream_table

Module snapshot

Structs§

SnapshotReadArgs
UpstreamTableReader
A wrapper of upstream table for snapshot read because we need to customize the snapshot read for managed upstream table (e.g. mv, index) and external upstream table.

Traits§

UpstreamTableRead

Functions§

with_additional_columns 🔒
Append additional columns with value as null to the snapshot chunk