Flink入門(十一) state狀態update更新

有這樣需求，統計每一個小時，一個線路被點擊次數， 須要每30秒統計一次寫入redis，採用Slide窗口滑動，但發現一個問題，當key沒有新的消息消費， 當（key，value）的value不變的，滑動統計仍是會輸出統計值，這個key的value就沒必需要寫入redis。 因此採用ValueState的update更新，web 代碼以下：redis DataStream<Tuple2<String

>>阅读原文<<