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

Implement a sort inside the WindowFunction

Hi all, I have a word count using flink stream and mey reduce transformations is applying a WindowFunction. I would like that this WindowFunction sort the output of the reduce. Is that possible? So I will sort by key the data set inside the window. Thanks for your ideas! Here is my code: