Module flownode_impl 

impl FlowNode trait for FlowNodeManager so standalone can call them

Structs

ConsistentCheckTask 🔒

FlowDualEngine

Manage both streaming and batching mode engine

SrcTableToFlow 🔒

Enums

FetchFromRow 🔒

Simple helper enum for fetching value from row with default value

Functions

decode_internal_eval_schedule 🔒

Decode typed schedule config from the internal transient key emitted by metasrv. Malformed JSON is an internal error rather than a reason to silently fall back.

to_meta_err 🔒

return a function to convert crate::error::Error to common_meta::error::Error

Type Aliases

FlowDualEngineRef

Ref to FlowDualEngine