Hi Anna, KeyedProcessFunction is only available starting from Flink 1.5. The doc is here <https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/process_function.html#the-keyedprocessfunction>. It extends ProcessFunction and shares the same functionalities except giving more access to timers' key, thus you can refer to examples of ProcessFunction in that document.
Bowen On Thu, Jul 19, 2018 at 3:26 PM anna stax <annasta...@gmail.com> wrote: > Hello all, > I am using Flink 1.4 because thats the version provided by the latest AWS > EMR. > Is KeyedProcessFunction available in Flink 1.4? > > Also please share any links to good examples on using KeyedProcessFunction > . > > Thanks >
