Skip to content
On this page

节点与算子

本文按 类别 说明组件库中的全部节点:中文名、端口数、配置字段、与相近节点的差异。类型定义见 数据模型。十五种节点均已提供配置 UI,并由 runCleanFlowLocal 实现本地变换。

类别与配色

类别category中文CSS 变量(节点强调色)
数据源source数据源--clean-cat-source(青)
清洗clean清洗--clean-cat-clean(琥珀)
合并merge合并--clean-cat-merge(紫)
聚合agg聚合--clean-cat-agg(靛)
输出output输出--clean-cat-output(绿)

端口与连线

每个类型在 NODE_TYPE_META 中声明 inputs / outputs

规则说明
输入在左、输出在右禁止从 in 拖到 out(方向校验)
inputs === 0源节点,无左侧 Handle
outputs === 0输出节点,无右侧 Handle
inputs >= 2左侧额外 in-left-top / in-left-bottom(Join / Union)
outputs === 2右侧 out-true(是)/ out-false(否),仅条件分支
普通单出out-right,并附带上下辅助出点便于一对多分发

常用 Handle id:

Handle含义
in-left主输入
in-left-top / in-left-bottom多输入辅助
out-right / out-right-top / out-right-bottom普通输出
out-true / out-false条件分支「是 / 否」

画布还禁止:自连、成环、同一 source+target+sourceHandle 重复边;整图仅允许一个 output 节点


数据源(source)

数据表 table

端口入 0 / 出 1
说明从建模或数据准备选择表 / 输出
配置 UI已实现(含字段勾选)
配置字段说明
sourceKindschema-table | dataset-table | dataset-output
refId / refLabel选中项 id 与展示名
tableId / tableName表标识
fieldsundefined/null = 全部;非空数组 = 投影;[] = 无字段

Demo 表示例(DEMO_SOURCE_OPTIONS):

  • 建模:demo_sales · orders / customersdemo_region · regions
  • Dataset 原始表:销售数据集 · orders / customers
  • Dataset 输出:销售数据集 · 查询输出

API 接口 api

端口入 0 / 出 1
说明从 HTTP 接口拉取数据
配置 UI已实现
配置字段默认
url''(可填 /demo/orders 等;留空用包内默认样例帧)
method'GET' | 'POST'

本地预览通过 resolveDemoApiFrame 解析 Demo 帧,不发起真实跨域请求。


清洗(clean)

空值处理 null-handle

端口1 / 1
说明填充 / 删除行 / 前后向填充
配置 UI已实现
字段取值
fields作用列
strategyfill | drop-row | ffill | bfill
fillValuestrategy=fill 时的填充值

格式标准化 format

端口1 / 1
说明手机号 / 日期 / 金额等格式
配置 UI已实现
字段取值
field目标列
formatphone | id-card | date | money | regex
patternregex 时的模式(含捕获组时取第 1 组)

去重 dedupe

端口1 / 1
说明按字段组合去重
配置 UI已实现
字段取值
fields判重键
keepfirst | last | random

去空格&大小写 trim-case

端口1 / 1
说明空格与大小写规范化
配置 UI已实现
字段取值
fields作用列
opstrim | trim-all | upper | lower | capitalize(可多选)

异常值处理 outlier

端口1 / 1
说明范围 / 正则 / 枚举校验
配置 UI已实现
字段取值
field目标列
rulerange | regex | enum
actionmark | drop | replace
replaceValueaction=replace 时替换值
min / maxrule=range
patternrule=regex
enumValuesrule=enum,逗号分隔合法值

条件过滤 filter

端口1 / 1
说明丢弃不满足条件的行
配置 UI已实现
字段说明
logic多条件组合:and | or(条件数 > 1 时显示)
conditions[]{ field, op, value }

界面提示:仅保留满足条件的行,不满足的行会被丢弃。

条件分支 condition

端口1 / 2
说明保留全部行,按条件分流到「是 / 否」两路下游
配置 UI已实现(表单与 filter 相同,语义不同)
字段说明
logic / conditionsCleanFilterConfig

界面提示:满足条件从右侧「是」出口流出,否则从「否」出口流出;两路均可继续连接下游。

filter vs condition

  • 过滤:行集合变小(不满足 → 删除)。
  • 分支:行集合按条件拆到两条管道,总量不变(分别进入不同下游)。

字段拆分 split-field

端口1 / 1
说明将一个字段拆分为多个字段
配置 UI已实现;预览随配置变化
字段说明
field源字段名
modedelimiter | regex | fixed-width
delimiter分隔符模式,如 , / | / 空格
pattern正则捕获组,如 ^(\\d{4})-(\\d{2})-(\\d{2})$
outputs输出字段列表;固定宽度可带 width
keepOriginal是否保留原字段,默认 true
padEmpty段数不足时是否用空值补齐,默认 true

示例:

  • 张三,李四 + 分隔符 ,first_name / last_name
  • 日期 2026-08-10 + 正则捕获 → 年 / 月 / 日三列

过滤运算符

FILTER_OP_OPTIONS(filter / condition 共用):

标签op是否需要 value
等于eq
不等于neq
大于gt
大于等于gte
小于lt
小于等于lte
包含contains
不包含not-contains
为空empty否(界面隐藏值输入)
不为空not-empty

组合逻辑:且 (AND) / 或 (OR)


合并(merge)

关联合并 join

端口2 / 1
说明LEFT / INNER / RIGHT / FULL JOIN
配置 UI已实现
字段说明
joinTypeleft | inner | right | full(默认 left
keys{ leftField, rightField }[]
outputFields输出列投影(可选)

连线时请把两路上游分别接到左侧不同输入锚点。

纵向合并 union

端口2 / 1
说明UNION 多路输入
配置 UI已实现
字段说明
dedupe是否去重,默认 false
fieldMap字段名映射;界面可用 右字段:左字段 逗号列表编辑

聚合(agg)

分组聚合 groupby

端口1 / 1
说明GROUP BY + 聚合度量
配置 UI已实现
字段说明
groupFields分组列
metrics{ field, fn, alias }[]fnSUM | COUNT | AVG | MAX | MIN

数据准备公式度量 不同:此处是节点级结构化聚合配置,不是自由公式文本。

透视表 pivot

端口1 / 1
说明行 / 列维度透视
配置 UI已实现
字段说明
rowField / colField / valueField行维、列维、值列
aggSUM | COUNT | AVG | MAX | MIN(默认 SUM

输出(output)

数据输出 output

端口1 / 0
说明流终点,供报表 / 页面调用时执行
配置 UI已实现(名称 + 目标 + 输出字段勾选)
字段说明
outputName输出名,默认「清洗输出」
targetreport(报表数据集)| lowcode(低代码页面数据源)| api(API 端点)
triggeron-demand | manual-preview(预留)
consumers{ id, name, kind: 'report'|'page' }[](预留)
fields最终输出投影;未配置默认全部,也可全部取消([]

界面提示:调用时执行;消费者绑定后续对接。画布上只能有一个输出节点。


节点速查表

type中文类别入/出配置 UI本地变换
table数据表source0/1
apiAPI 接口source0/1✅(Demo 帧)
null-handle空值处理clean1/1
format格式标准化clean1/1
dedupe去重clean1/1
trim-case去空格&大小写clean1/1
outlier异常值处理clean1/1
filter条件过滤clean1/1
condition条件分支clean1/2
split-field字段拆分clean1/1
join关联合并merge2/1
union纵向合并merge2/1
groupby分组聚合agg1/1
pivot透视表agg1/1
output数据输出output1/0

相关文档