Custom Window example (data-based)

[chrisr123]

I want to get some experience implementing a custom window assigner, trigger,
evictor, etc.
Does anyone have an example of a custom window implementation that I could
look at, or an
idea for one to implement? The goal is to learn the custom window API. I'm
looking for something
besides a time or count window. The trigger would be based on some
attribute(s) of the data.
Thanks!




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[vino yang]

Hi Chris,

I just find some resource you can have a look, list below:

• Flink official documentation : https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/stream/operators/windows.html#built-in-and-custom-triggers
• Custom, Complex Windows at Scale using Apache Flink(video): https://www.youtube.com/watch?v=XUvqnsWm8yo
  
• Custom, Complex Windows @Scale Using Apache Flink(video): https://www.infoq.com/presentations/events-windows-apache-flink
  
• Custom Trigger : https://gist.github.com/mxm/c5831ead9c9d9ad68731f5f2f3793154
• Flink training about Window and aggregation : https://www.slideshare.net/dataArtisans/apache-flink-training-datastream-api-windows-time

Hope some of them can help you.

Thanks, vino.

2018-07-27 19:40 GMT+08:00 chrisr123 <[hidden email]>:

I want to get some experience implementing a custom window assigner, trigger,
evictor, etc.
Does anyone have an example of a custom window implementation that I could
look at, or an
idea for one to implement? The goal is to learn the custom window API. I'm
looking for something
besides a time or count window. The trigger would be based on some
attribute(s) of the data.
Thanks!




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/