使用scala編寫flink消費kafka實時計算pv,uv

實時統計pv、uv是再常見不過的大數據統計需求了，前面出過一篇SparkStreaming實時統計pv,uv的案例，這裏用flink實時計算pv,uv。 我們需要統計不同數據類型每天的pv，uv情況,並且有如下要求. 每秒鐘要輸出最新的統計結果 程序永遠跑着不會停,所以要定期清理內存裏的過時數據 收到的消息裏的時間字段並不是按照順序嚴格遞增的,所以要有一定的容錯機制 訪問uv並不一定每秒鐘都會變化

>>阅读原文<<