其他
Flink从入门到放弃-DataSetAPI&DataStream API
大数据成神之路:点我去成神之路系列目录^_^
...
预计更新500+篇文章,已经更新100+篇~
导语
本节课是关于Flink的编程模型中重要的API:DataSetAPI&DataStream API,另外文章中初步涉及到了窗口的广播的概念,不要慌,后面有专门的章节进行介绍。
1DataSetAPI
分类:
Source: 数据源创建初始数据集,例如来自文件或Java集合
Transformation: 数据转换将一个或多个DataSet转换为新的DataSet
Sink: 将计算结果存储或返回
2DataStreamAPI
DataStream算子将一个或多个DataStream转换为新DataStream。程序可以将多个转换组合成复杂的数据流拓扑。
DataStreamAPI和DataSetAPI主要的区别在于Transformation部分。