我想计算用户ID的数量所以我给流中的每个元素分配了1,我想获得每个uid的点击次数如何使用“时间”窗口计数元素?
val dis_uid=display.map(_.split(",")).map(x=>(keyuid(x),1.0)) .keyBy(x=>x._1._1) .timeWindow(Time.seconds(30)) .apply(?)
the examples that ship with Flink中有开窗的例子,the self-paced training中有一个关于该主题的教程。
您可以使用https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/WindowWordCount.scala作为起点。