键控Datastream API flink中元素的数量

问题描述 投票:0回答:1

我想计算用户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(?)
scala apache-flink data-stream
1个回答
© www.soinside.com 2019 - 2024. All rights reserved.