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

to_meta_err 🔒

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

Type Aliases

FlowDualEngineRef

Ref to FlowDualEngine