0
点赞
收藏
分享

微信扫一扫

大数据_Flink_Java版_数据处理_流处理API_Sink操作_Kafka---Flink工作笔记0038

惠特曼 2022-03-12 阅读 60

    上面我们说了数据的转换处理,数据处理以后,我们经过sink处理,就是进行存储对吧,

这里可以存入csv文件,存入text文件等.

 

然后我们再来看,我们如何把数据处理完了以后,存入到kafka中,

我们写个测试类SinkTest_Kafka

我们同样从别的地方copy过来,之前的代码,包含

从文件中读取数据,然后,把数据输入流inputStream,通过.map方法,把数据转换成

SensorReading,这个

举报

相关推荐

0 条评论