flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Radu Tudoran <radu.tudo...@huawei.com>
Subject RE: Custom time window in Flink
Date Wed, 20 Apr 2016 09:20:23 GMT

Tha way to do this is to create your own evictor. In the evictor you can than decide when
the events are removed. I would suggest creating a symmetric trigger as well because I would
assume that you also need to fire the computation first after 1 hour and then at each 5 minutes.
The logic would be that you have a field that marks whether a window was created or not (e.g.,
a Boolean field in the evictor class), which once a window is created you can set it to false
and from there one you operate on 5 minutes windows

Dr. Radu Tudoran
Research Engineer - Big Data Expert
IT R&D Division

European Research Center
Riesstrasse 25, 80992 München

E-mail: radu.tudoran@huawei.com
Mobile: +49 15209084330
Telephone: +49 891588344173

Hansaallee 205, 40549 Düsseldorf, Germany, www.huawei.com<http://www.huawei.com/>
Registered Office: Düsseldorf, Register Court Düsseldorf, HRB 56063,
Managing Director: Bo PENG, Wanzhou MENG, Lifang CHEN
Sitz der Gesellschaft: Düsseldorf, Amtsgericht Düsseldorf, HRB 56063,
Geschäftsführer: Bo PENG, Wanzhou MENG, Lifang CHEN
This e-mail and its attachments contain confidential information from HUAWEI, which is intended
only for the person or entity whose address is listed above. Any use of the information contained
herein in any way (including, but not limited to, total or partial disclosure, reproduction,
or dissemination) by persons other than the intended recipient(s) is prohibited. If you receive
this e-mail in error, please notify the sender by phone or email immediately and delete it!

From: Piyush Shrivastava [mailto:piyushjoy@yahoo.co.in]
Sent: Wednesday, April 20, 2016 9:59 AM
To: user@flink.apache.org
Subject: Custom time window in Flink

I wanted to enquire how a job I am trying to do with Flink can be done.
I have also posted a question on StackOverflow. PFB the link:

I am using Flink's TimeWindow functionality to perform some computations. I am creating a
5 minute Window. However I want to create a one hour Window for only the first time. The next
Windows I need are of 5 minutes.
Such that for the first hour, data is collected and my operation is performed on it. Once
this is done, every five minutes the same operation is performed.

Can you kindly help me with this? How can such a functionality be implemented?

Thanks and Regards,
Piyush Shrivastava<mailto:piyush@webograffiti.com>
View raw message