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
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 写道:
>>>
>>> 各位好!
>>> 祝大家新年快乐!
过期数据能通过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(),每隔固定时间计算一次,并且输出,并且不保留已经计算的数据
> --问题
: 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 1.9.1 ON YARN
--过程
1.定义一个 EventTimeSessionWindows.withGap(Time.hours(1))窗口
2.定义一个new Trigger(),每隔固定间隔计算一次,并且输出
3.定义一个new ProcessWindowFunction(),每隔固定时间计算一次,并且输出,并且不保留已经计算的数据
--问题
new ProcessWindowFunction()中通过iter.remove();来将计算过的数据去掉,