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

小_北_爸

 关注

阅读 31

2022-03-26

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

用这个KeyedProcessFunction

 

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

需要传入一个keyedprocessFunction

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

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

相关推荐

大数据_Flink_Java版_并行任务WaterMark传递测试---Flink工作笔记0064

福福福福福福福福福 34 0 0

大数据_Flink_Java版_状态管理(2)_算子状态---Flink工作笔记0061

未定义变量 40 0 0

大数据_Flink_Java版_状态管理(3)_键控状态---Flink工作笔记0062

yongxinz 56 0 0

大数据_Flink_Java版_容错机制(5)-保存点---Flink工作笔记0074

RockYoungTalk 58 0 0

大数据_Flink_Java版_Table API 和 Flink SQL(15)_开窗函数---Flink工作笔记0095

夏沐沐 160 0 0

大数据_Flink_Java版_Table API 和 Flink SQL(14)_分组窗口---Flink工作笔记0094

凶猛的小白兔 50 0 0

大数据_Flink_Java版_数据处理_Window_API(3)_计数窗口测试---Flink工作笔记0048

ZSACH 57 0 0

大数据_Flink_Java版_Table API 和 Flink SQL(16)_系统内置函数---Flink工作笔记0096

沪钢木子 68 0 0

大数据_Flink_Java版_Table API 和 Flink SQL(13)_事件时间特性---Flink工作笔记0093

灵魂跑者 52 0 0

大数据_Flink_Java版_数据处理_Window_API(3)_计数窗口测试---Flink工作笔记0047

J简文 45 0 0

精彩评论（0）

0 0 举报