flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hironori Ogibayashi <ogibaya...@gmail.com>
Subject Re: tumbling time window, date boundary and timezone
Date Mon, 01 Aug 2016 09:59:28 GMT
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 <aljoscha@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 <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