Re: Implement a sort inside the WindowFunction

thanks Fabian, I am building an example and generating my own fake source to process in Flink. I am going to implement more stuff with keys and event time processing t

Re: Implement a sort inside the WindowFunction

Hi Felipe, Just like the ReduceFunction, the WindowFunction is applied in the context of a single key. So, it will be called for each key and always just see a single record (the reduced record of the key). You'd have to add a non-keyed window (allWindow) for your sorting WindowFunction. Note that