Module adapter 

Flow source schema management and stateless streaming execution.

Modules

flownode_impl 🔒

impl FlowNode trait for FlowNodeManager so standalone can call them

stateless 🔒

Stateless DataFusion execution for streaming flows.

table_source 🔒

How to query table information from database

util 🔒

Util functions for adapter

Structs

FlowConfig

FlownodeOptions

StatelessFlowRuntime 🔒

StatelessFlowSlot 🔒

StreamingEngine

Enums

FetchFromRow 🔒

Constants

AUTO_CREATED_PLACEHOLDER_TS_COL

AUTO_CREATED_UPDATE_AT_TS_COL

Functions

default_num_workers 🔒

is_explicit_source_timestamp_compatibility 🔒

Returns whether an existing sink uses the legacy explicit source-time-index layout.

output_column_schemas 🔒

Converts a retained plan’s output to logical schemas. Only a direct source column (optionally wrapped in an alias) carries source semantics; computed expressions deliberately use the physical output field metadata instead.

relation_desc_from_output 🔒

resolve_sink_layout 🔒

Resolves the columns appended by the flow, validating the complete output/sink layout.

sink_output_column_count 🔒

Legacy helper for callers that only have a sink schema. New stateless flows resolve the suffix against both schemas and store it in StatelessFlow.

validate_auto_column_names 🔒

validate_captured_slot 🔒

validate_sink_layout 🔒

validate_sink_layout_with_suffix 🔒

Type Aliases

FlowStreamingEngineRef