求nebula-flinker处理数据代码

需求,从kafka消费数据json0,并通过flinker生成VID,根据生成的VID读取其他图空间相同图的数据json1,拼接json0和json1相同tag的值得到json2,把生成的json2写入nebula中

请参考
https://github.com/vesoft-inc/nebula-flink-connector

nebula-flink中间可以加入数据处理的过程么,和原始flink是不是没有区别?