组件介绍

应用场景

CDC或者MQ中的实时流数据如果选择传入本组件，则本组件会对实时流中的数据字段进行转换、清洗等操作，通过本组件可以让实时流数据与批数据进行合并以打宽实时数据表，如实时数据中只有userid但是并没有username字段，而username可能在另一个SQL表中，就可以让实时流通过合并username字段到实时流中，这样实时流数据就实现了与批表中的数据进行合并的效果。

组件界面

可以对实时流中的字段绑定规则进行实时运算和转换 读取到的字符串必须要返回[{data1},{data2}]格式的数组json

应用示例

使用提示

1.本组件为系统自带组件,从左则菜单中拉入即可使用
2.需要与CDC或MQ实时数据集成的中的监听任务进行配合使用也支持通过Restful API传入实时流数据进行处理
3.实时流数据可以与其他SQL节点，库表输入节点配合使用，以打宽实时数据流中的字段或者进行数据质量检测
4.实时输入流节点后面的路由线的执行顺序要标识为1，后面并行T00003节点后面的路由线要标识顺序为2才能正常合并数据

使用评价