Flink从入门到放弃-DataSetAPI&DataStream API

大数据成神之路：

点我去成神之路系列目录^_^

• Java高级特性增强-集合
• Java高级特性增强-多线程
• Java高级特性增强-Synchronized
• Java高级特性增强-volatile
• Java高级特性增强-并发集合框架
• Java高级特性增强-分布式
• Java高级特性增强-Zookeeper
• Java高级特性增强-JVM
• Java高级特性增强-NIO
• ...

预计更新500+篇文章，已经更新100+篇~

导语

本节课是关于Flink的编程模型中重要的API:DataSetAPI&DataStream API,另外文章中初步涉及到了窗口的广播的概念，不要慌，后面有专门的章节进行介绍。

1DataSetAPI

分类：

• Source: 数据源创建初始数据集，例如来自文件或Java集合
• Transformation: 数据转换将一个或多个DataSet转换为新的DataSet
• Sink: 将计算结果存储或返回

2DataStreamAPI

DataStream算子将一个或多个DataStream转换为新DataStream。程序可以将多个转换组合成复杂的数据流拓扑。

DataStreamAPI和DataSetAPI主要的区别在于Transformation部分。

长按识别二维码关注'大数据成神之路',从小白到大神~

点击原文链接，跳到原文观看。