Flink使用SideOutPut替換Split實現分流
以前的數據分析項目(版本1.4.2),對從Kafka讀取的原始數據流,調用split接口實現分流. 新項目決定使用Flink 1.7.2,使用split接口進行分流的時候,發現接口被標記為deprac ...
以前的數據分析項目(版本1.4.2),對從Kafka讀取的原始數據流,調用split接口實現分流. 新項目決定使用Flink 1.7.2,使用split接口進行分流的時候,發現接口被標記為deprac ...