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

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

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

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

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

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