Module adapter

Expand description

for getting data from source and sending results to sink and communicating with other parts of the database

Modules§

flownode_impl 🔒: impl FlowNode trait for FlowNodeManager so standalone can call them
node_context 🔒: Node context, prone to change with every incoming requests
parse_expr 🔒: parse expr like “ts <= now() - interval ‘5 m’”
refill 🔒: This module contains the refill flow task, which is used to refill flow with given table id and a time range.
stat 🔒
table_source 🔒: How to query table information from database
util 🔒: Util functions for adapter
worker 🔒: For single-thread flow worker

FlowConfig: Flow config that exists both in standalone&distributed mode
FlowTickManager: FlowTickManager is a manager for flow tick, which trakc flow execution progress
FlownodeOptions: Options for flow node
StreamingEngine: FlowNodeManager manages the state of all tasks in the flow node, which should be run on the same thread