flink-demo-根據事件時間觸發窗口計算

1.數據： 目標： 使用的api 代碼實現 1. 生產者 2. 消費者 測試 1.啓動 2.輸入 3.輸出 1.數據： 事件的格式爲　abc,3,20180503-110301java abc:統計的key值 3: key值的個數 20180503-110301: 事件時間戳 目標： 使用kafka存儲產生的事件，而後用flink進行消費，採用flink的窗口機制，根據事件的時間戳，當兩個事件的時

>>阅读原文<<