0
点赞
收藏
分享

微信扫一扫

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

guanguans 2022-03-11 阅读 46

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

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

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

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

这个是温度数据.

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

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

SourceTest1_Collection 这个类

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

 

举报

相关推荐

0 条评论