更新时间:2022-12-09 GMT+08:00
分享

更新域

概述

“更新域”算子,当满足某些条件时,更新字段的值。

目前支持的类型有“BIGINT”“DECIMAL”“DOUBLE”“FLOAT”“INTEGER”“SMALLINT”“VARCHAR”。当类型为“VARCHAR”时,运算符为“+”时,表示在字符串后追加串,不支持“-”,当为其它类型时,“+”“-”分别表示值的加和减。针对支持的所有类型,运算符“=”都表示直接赋新值。

输入与输出

输入:字段

输出:输入字段

参数说明

表1 算子参数说明

参数

含义

类型

是否必填

默认值

更新字段名

需要更新的字段

string

操作符

操作符,支持“+”“-”“=”

enum

+

更新值

用来更新的值

与字段类型相匹配

条件逻辑连接符

配置条件逻辑连接符,可配置“AND”“OR”

enum

AND

条件

配置过滤条件相关信息:

  • 输入字段名:配置输入字段名,需填写上一个转换步骤生成的字段名。
  • 操作:配置操作符。
  • 比较值:配置比较值,可直接输入值或输入“#{已存在的字段名}”格式引用字段的具体值。

map

数据处理规则

  • 首先判断条件是否成立。如果成立,更新字段的值;如果不成立,则不更新。
  • 当更新字段为数值类型时,更新值需要为数值。
  • 当更新字段为字符串类型时,更新操作不能为“-”

样例

通过“CSV文件输入”算子,生成两个字段A和B。

源文件如下:

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

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

相关文档