带你读《Flink原理、实战与性能优化》之三:Flink编程模型

  1. 云栖社区>
  2. 华章计算机>
  3. 博客>
  4. 正文

带你读《Flink原理、实战与性能优化》之三:Flink编程模型

温柔的养猫人 2019-11-01 16:22:13 浏览1094
展开阅读全文

点击查看第一章
点击查看第二章

第3章

Flink编程模型
本章将重点介绍Flink编程模型中的基本概念和编写Flink应用程序所遵循的基本模式。其中,包括Flink支持的数据集类型,有界数据集和无界数据集的区别,以及有界数据集和无界数据集之间的转换。同时针对无界和有界数据集的处理,将介绍Flink分别提供对应的开发接口DataStream API和DataSet API的使用。然后介绍Flink程序结构,包括基本的Flink应用所包含的组成模块等。最后介绍Flink所支持的数据类型,包括常用的POJOs、Tuples等数据类型。

3.1 数据集类型

现实世界中,所有的数据都是以流式的形态产生的,不管是哪里产生的数据,在产生的过程中都是一条条地生成,最后经过了存储和转换处理,形成了各种类型的数据集。如图3-1所示,根据现实的数据产生方式和数据

网友评论

登录后评论
0/500
评论
温柔的养猫人
+ 关注
所属团队号: 华章计算机