flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: tumbling time window, date boundary and timezone
Date Fri, 29 Jul 2016 10:29:24 GMT
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 <ogibayashi@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
>

Mime
View raw message