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 Liu Join <lz...@outlook.com> on 2023/08/11 02:59:13 UTC

关于RichFlatMapFunction的状态输出

请问，flink1.17在使用RichFlatMapFunction进行批计算时，如何在数据结束时将状态写入输出的数据流中？
谢谢

Re: 关于RichFlatMapFunction的状态输出

Posted by Shammon FY <zj...@gmail.com>.

Hi,

是想在RichFlatMapFunction结束计算前输出一些信息吗？AbstractRichFunction里有close方法，可以实现这个方法执行一些自定义的操作，这样在function
close之前会执行

Best,
Shammon FY

On Fri, Aug 11, 2023 at 10:59 AM Liu Join <lz...@outlook.com> wrote:

> 请问，flink1.17在使用RichFlatMapFunction进行批计算时，如何在数据结束时将状态写入输出的数据流中？
> 谢谢
>