xfhmbjs 2023-07-29 20:28 采纳率: 0%
浏览 16
已结题

flink,一个小时内，电话号码出现10次的,都要进行输出，以数据的时间为准

在flink 中，要对输入的数据流进行处理。输入的数据流中每行数据有2个字段，电话号码 和 号码出现的时间戳。
现在要处理数据的逻辑是，一个小时内，电话号码出现10次的，都要进行输出。
这段代码该怎么编写，使用java语言
注意：1.时间以号码的时间戳为准，不是系统时间
2.使用滚动窗口是不是有临界问题，就是一个窗口出现5次，第二个窗口出现5次，但是这10次出现都在1个小时内

  • 写回答

11条回答 默认 最新

  • coder_small_bell 2023-07-29 21:47
    关注
    获得2.10元问题酬金

    直接flink权威指南有各种

    评论

报告相同问题？

问题事件

  • 系统已结题 8月6日
  • 创建了问题 7月29日