Is KeyedProcessFunction available in Flink 1.4?

[anna stax]

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

[phoenixjiangnan]

Hi Anna,

KeyedProcessFunction is only available starting from Flink 1.5. The doc is here. 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 <[hidden email]> 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

[anna stax]

Thanks Bowen. 

On Thu, Jul 19, 2018 at 4:45 PM, Bowen Li <[hidden email]> wrote:

Hi Anna,

KeyedProcessFunction is only available starting from Flink 1.5. The doc is here. 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 <[hidden email]> 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