Re:Re: FLINK 不同 StateBackend ProcessWindowFunction的差别

2020-01-07 文章 USERNAME
b/streaming/state/RocksDBListState.java#L119 > >祝好 >唐云 > > >From: USERNAME >Sent: Tuesday, January 7, 2020 17:54 >To: user-zh@flink.apache.org >Subject: FLINK 不同 StateBackend ProcessWindowFunction的差别 > >各位好! >祝大家新年快乐! > > &g

Re:Re:Re: FLINK 不同 StateBackend ProcessWindowFunction的差别

2020-01-07 文章 USERNAME
TTL 好像不支持 TimeCharacteristic.EventTime 方式 在 2020-01-08 14:17:11,"USERNAME" 写道: >我这例子需要通过 在触发器中 TriggerResult.FIRE_AND_PURGE 来清理当前计算窗口的数据,实现增量计算,跟TTL有点区别吧。 > > > > > >在 2020-01-07 19:51:57,"huoguo" 写道: >> >> >>过期数据能通过TTL 设置过期吗? >> >>> 在 2020年1月7日,17:54,USERNAME 写道: >>> >>> 各位好! >>> 祝大家新年快乐!

Re: FLINK 不同 StateBackend ProcessWindowFunction的差别

2020-01-07 文章 huoguo
过期数据能通过TTL 设置过期吗? > 在 2020年1月7日,17:54,USERNAME 写道: > > 各位好! > 祝大家新年快乐! > > > > > --版本 > FLINK 1.9.1 ON YARN > > > --过程 > 1.定义一个 EventTimeSessionWindows.withGap(Time.hours(1))窗口 > 2.定义一个new Trigger(),每隔固定间隔计算一次,并且输出 > 3.定义一个new ProcessWindowFunction(),每隔固定时间计算一次,并且输出,并且不保留已经计算的数据 > --问题

Re: FLINK 不同 StateBackend ProcessWindowFunction的差别

2020-01-07 文章 Yun Tang
: Tuesday, January 7, 2020 17:54 To: user-zh@flink.apache.org Subject: FLINK 不同 StateBackend ProcessWindowFunction的差别 各位好! 祝大家新年快乐! --版本 FLINK 1.9.1 ON YARN --过程 1.定义一个 EventTimeSessionWindows.withGap(Time.hours(1))窗口 2.定义一个new Trigger(),每隔固定间隔计算一次,并且输出 3.定义一个new ProcessWindowFunction(),每隔固定时间计算一次

FLINK 不同 StateBackend ProcessWindowFunction的差别

2020-01-07 文章 USERNAME
各位好! 祝大家新年快乐! --版本 FLINK 1.9.1 ON YARN --过程 1.定义一个 EventTimeSessionWindows.withGap(Time.hours(1))窗口 2.定义一个new Trigger(),每隔固定间隔计算一次,并且输出 3.定义一个new ProcessWindowFunction(),每隔固定时间计算一次,并且输出,并且不保留已经计算的数据 --问题 new ProcessWindowFunction()中通过iter.remove();来将计算过的数据去掉,