Aljoscha,
Thank you for your response.
It would be great if offset setting is available out-of-the box.
In the meantime, I will use my custom version.
Regards,
Hironori
2016-07-29 19:29 GMT+09:00 Aljoscha Krettek :
> Hi,
> yes, I'm afraid you would have to use a custom version of the
> TumblingP
Hi,
yes, I'm afraid you would have to use a custom version of the
TumblingProcessingTimeWindows right now.
I've opened a Jira issue for adding an offset setting to the built-in
window assigners: https://issues.apache.org/jira/browse/FLINK-4282
Cheers,
Aljoscha
On Tue, 26 Jul 2016 at 12:51 Hirono
Hello,
I want to calculate daily access count using Flink streaming.
Flink's TumblingProcessingTimeWindow assigns events to windows of
00:00 GMT to 23:59 GMT each day, but I live in Japan (GMT+09:00) and
want date boundaries to be 09:00 GMT (00:00 JST).
Do I have to implement my own WindowAssigner
