花费 16 ms
Flink使用SideOutPut替换Split实现分流

以前的数据分析项目(版本1.4.2),对从Kafka读取的原始数据流,调用split接口实现分流. 新项目决定使用Flink 1.7.2,使用split接口进行分流的时候,发现接口被标记为deprac ...

Mon Sep 30 05:32:00 CST 2019 0 1356

 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM