Flink DataStream Micro-Batch

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink DataStream Micro-Batch

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

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

感谢!
Reply | Threaded
Open this post in threaded view
|

Re: Flink DataStream Micro-Batch

Utopia
用 Window 实现。
2019年10月22日 +0800 13:25 王佩 <[hidden email]>,写道:
> 想在Flink DataStream中实现微批,可以做到吗。该如何实现?
>
> 比方说基于处理时间,从Kafka 消费数据,每隔5s产生一个Batch,然后对这个Batch处理。
>
> 感谢!