花費 20 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