You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 王佩 <wa...@cmcm.com> on 2019/10/22 05:25:24 UTC

Flink DataStream Micro-Batch

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

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

感谢！

Re: Flink DataStream Micro-Batch

Posted by Utopia <ge...@gmail.com>.

用 Window 实现。
2019年10月22日 +0800 13:25 王佩 <wa...@cmcm.com>，写道：
> 想在Flink DataStream中实现微批，可以做到吗。该如何实现？
>
> 比方说基于处理时间，从Kafka 消费数据，每隔5s产生一个Batch，然后对这个Batch处理。
>
> 感谢！