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