大数据_Flink_Java版_ProcessFunction(2)_KeyedProcessFunction测试---Flink工作笔记0067

然后我们来看,了解了ProcessFunction都有什么以后,我们来做一个测试.

用这个KeyedProcessFunction

首先我们去看一下在这个KeyedStream中有个process方法,这个方法中可以看到

需要传入一个keyedprocessFunction

然后这个keyedProcessFunction可以看到,参数是K,I,O K是当前keyby用的key,然后I是数据的数据,

然后O是输出的数据,然后继承Abs