Re: tumbling time window, date boundary and timezone

Posted by Aljoscha Krettek on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/tumbling-time-window-date-boundary-and-timezone-tp8140p8194.html

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 <[hidden email]> 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