Custom Window example (data-based)

[chrisr123 <ch...@gmail.com>]

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/

Re: Custom Window example (data-based)

[vino yang <ya...@gmail.com>]

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 <ch...@gmail.com>:

> 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/
>