You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Hironori Ogibayashi <og...@gmail.com> on 2016/07/26 10:50:57 UTC

tumbling time window, date boundary and timezone

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

Re: tumbling time window, date boundary and timezone

Posted by Hironori Ogibayashi <og...@gmail.com>.
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 <al...@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 <og...@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

Re: tumbling time window, date boundary and timezone

Posted by Aljoscha Krettek <al...@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 <og...@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
>