Expand description
Stateless DataFusion execution for streaming flows.
Structs§
- Stateless
Flow 🔒 - The validated, immutable part of one streaming flow.
Functions§
- execute 🔒
- Executes one mirror write using only the supplied batch and writes its output.
- input_
provider 🔒 - replace_
source 🔒 - rewrite_
source_ 🔒timestamp - Adds the source timestamp to every supported plan node that has to carry it through a filter or projection. The expression is appended only after the visible expressions, so the sink contract remains positional.
- synthesize_
auto_ 🔒values - validate_
plan 🔒 - Validates the deliberately small stateless streaming SQL subset.
- validate_
source_ 🔒scan - Ensures the retained scan was planned against the source metadata captured for this flow.
- validate_
source_ 🔒schema_ version - Rejects execution when the source metadata changed after the flow plan was retained. The outer adapter replans a flow when it observes a new source schema version; this guard rejects a request if the version changes again before execution.