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 >
