@nanami 2021-08-03 10:23 采纳率: 60%
浏览 40
已结题

flink支持对对窗口内数据过滤吗?

开了一个滑动窗口,步长1分钟,窗口大小24小时,但是只想要当天的数据。窗口数据跨天时候可以利用相关的时间字段将窗口内的非当天数据过滤再计算吗?

  • 写回答

1条回答 默认 最新

  • syyyyyyyyyyyyyyh 2021-08-03 15:34
    关注

    超过00:00的数据如果不需要,直接放入测流就好。不管是后续使用还是丢掉。
    或者本身就有时间字段,直接加filter算子过滤不参与flink计算就好。

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

  • 专家修改了标签 5月17日
  • 系统已结题 11月2日
  • 已采纳回答 10月25日
  • 创建了问题 8月3日