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 <aljos...@apache.org>: > 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 Hironori Ogibayashi <ogibaya...@gmail.com> > wrote: >> >> 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 for this use case? >> >> Thanks, >> Hironori Ogibayashi
