在同步过程中需要变换某个字段的值，但是没生效，请问如何修改
代码如下。功能就是像把phone字段的号码去掉中间4位同步出去，实际使用过程中还是原样同步过去了。
package com.alibaba.otter.node.extend.processor;
import com.alibaba.otter.shared.etl.model.EventColumn; import com.alibaba.otter.shared.etl.model.EventData;
public class PhoneUserEventProcessor extends AbstractEventProcessor {
public boolean process(EventData eventData) { for (EventColumn column : eventData.getColumns()) { //对手机号码进行转换处理 if(column.getColumnName().equalsIgnoreCase("phone")){ String oriphone = column.getColumnValue(); System.out.println("process column phone:"+oriphone); if(oriphone != null && oriphone.length() == 11){ column.setColumnValue(oriphone.substring(0, 3)+"****"+oriphone.substring(7)); } } }
return true;
}
原提问者GitHub用户 lixqhuoli
写回答
-
1、检查下是否processor配置未生效
2、打开load详细日志看看具体的数据
原回答者GitHub用户agapple
2023-06-21 17:57:32赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
