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

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

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

   父主题: 转换算子