开发者社区> 问答> 正文

想在Flink DataStream中实现微批,可以做到吗。该如何实现?

想在Flink DataStream中实现微批,可以做到吗。该如何实现?

比方说基于处理时间,从Kafka 消费数据,每隔5s产生一个Batch,然后对这个Batch处理。

感谢!*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-08 10:15:42 641 0
1 条回答
写回答
取消 提交回答
  • 用 Window 实现。

    *来自志愿者整理的flink邮件归档

    2021-12-08 11:07:57
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载