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

J简文

 关注

阅读 45

2022-03-12

然后我们继续来看一下计数窗口测试,可以看到上面

WindowTest2_CountWindow,我们新创建一个类来实现这个功能.

 

首先前面的代码是一样的,首先,获取环境,然后,设置并行度是1

 

然后我们从socket中获取数据流.

然后对数据流字符串进行map处理成SensorReading流.

 

相关推荐

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

ZSACH 57 0 0

大数据_Flink_Java版_数据处理_Window_API(3)_窗口分配器---Flink工作笔记0044

幺幺零 48 0 0

大数据_Flink_Java版_数据处理_Window_API(4)_窗口函数_时间窗口_增量聚合---Flink工作笔记0045

大漠雪关山月 87 0 0

大数据_Flink_Java版_数据处理_Window_API(2)_窗口函数(2)_时间窗口_全窗口聚合---Flink工作笔记0046

全栈学习笔记 43 0 0

大数据_Flink_Java版_数据处理_Window_API_基本概念---Flink工作笔记0042

登高且赋 42 0 0

大数据_Flink_Java版_数据处理_事件时间语义下的窗口测试(1)---Flink工作笔记0057

秦瑟读书 81 0 0

大数据_Flink_Java版_数据处理_流处理API_Transform(4)_分流---Flink工作笔记0032

柠檬的那个酸_2333 69 0 0

大数据_Flink_Java版_数据处理_事件时间语义下的窗口测试(2)_迟到数据处理---Flink工作笔记0059

前端王祖蓝 63 0 0

大数据_Flink_Java版_数据处理_流处理API_Flink支持的数据类型---Flink工作笔记0035

扒皮狼 42 0 0

大数据_Flink_Java版_数据处理_流处理API_Transform(5)_union合流---Flink工作笔记0034

霍华德 64 0 0

精彩评论（0）

0 0 举报