Expand description
Logic related to the creation of dataflow sources.
See render_source
for more details.
Structs§
- KV 🔒After handling metadata insertion, we split streams into key/value parts for convenience
Functions§
- Convert from streams of
DecodeResult
to Rows, inserting the Key according toKeyEnvelope
- Handle possibly missing key or value portions of messages
- Renders complete differential
Collection
s that represent the final source and its errors as requested by the originalCREATE SOURCE
statement, encapsulated in the passedSourceInstanceDesc
. - Completes the rendering of a particular source stream by applying decoding and envelope processing as necessary
- Convert from streams of
DecodeResult
to UpsertCommands, inserting the Key according toKeyEnvelope