更新域
概述
“更新域”算子,当满足某些条件时,更新字段的值。
目前支持的类型有“BIGINT”、“DECIMAL”、“DOUBLE”、“FLOAT”、“INTEGER”、“SMALLINT”、“VARCHAR”。当类型为“VARCHAR”时,运算符为“+”时,表示在字符串后追加串,不支持“-”,当为其它类型时,“+”、“-”分别表示值的加和减。针对支持的所有类型,运算符“=”都表示直接赋新值。
输入与输出
输入:字段
输出:输入字段
参数说明
参数 | 含义 | 类型 | 是否必填 | 默认值 |
|---|---|---|---|---|
更新字段名 | 需要更新的字段 | string | 是 | 无 |
操作符 | 操作符,支持“+”、“-”和“=” | enum | 是 | + |
更新值 | 用来更新的值 | 与字段类型相匹配 | 否 | 无 |
条件逻辑连接符 | 配置条件逻辑连接符,可配置“AND”或“OR”。 | enum | 是 | AND |
条件 | 配置过滤条件相关信息:
| map | 是 | 无 |
数据处理规则
- 首先判断条件是否成立。如果成立,更新字段的值;如果不成立,则不更新。
- 当更新字段为数值类型时,更新值需要为数值。
- 当更新字段为字符串类型时,更新操作不能为“-”。
样例
通过“CSV文件输入”算子,生成两个字段A和B。
源文件如下:

配置“更新域”算子,当发现值为test时,更新值,在test后面加上good。

转换后,输出A和B,结果如下:


