大数据_Flink_数据处理_流处理API_Source_从集合读取数据---Flink工作笔记0025

guanguans

关注

阅读 47

2022-03-11

然后前面我们看完了,创建环境以后,然后我们再来看

source的部分,也就是读取数据源

1.可以看到首先我们来去读取集合数据,这里模拟一个从传感器读取数据,

比如上面sensor_1是传感器的编号,然后15477...是数据产生的时间,然后35.8等

这个是温度数据.

然后我们去写代码,首先创建一个package

com.atguigu.apitest.sources 然后里面写上一个

SourceTest1_Collection 这个类

然后com.atguigu.apitest.beans这个包,我们再创建这个包

 

精彩评论(0)

0 0 举报