DataX的transformer过滤字段中换行符的通用方法

 "transformer": [

        {

                "name": "dx_groovy",

                "parameter": {

                        "code": "for(int i=0;i<record.getColumnNumber();i++){if(record.getColumn(i).getByteSize()!=0){Column column = record.getColumn(i); def str = column.asString(); def newStr=null; newStr=str.replaceAll(\"[\\r\\n]\",\"\"); record.setColumn(i, new StringColumn(newStr)); };};return record;",

                        "extraPackage":[]

                }

        }

]

设置transformer过滤模块,

使用dx_groovy参数,

在code里面配置相应的代码。

可以找相应的源码,里面是将code拼成类,然后反射出来。作用于record对象。

所以写代码就对record对象操作就行了。


版权声明:本文为zx1007574931原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。