flink按字段對齊的流合併的實現

flink按字段對齊的流合併的實現 最近在用flink重構storm程序，遇到了一些問題，其中比較麻煩的就是storm中的流合併如何在flink中實現。java 需求根據每條數據內的時間屬性（同一類型的字段），拼裝同一時間的多個流數據爲一個流數據，儘量保證只要能合併的數據時間戳對齊。在storm中經過fieldGrouping能夠很簡單的實現。api .fieldsGrouping("test1"

>>阅读原文<<