从0到1学会 Flink
2024-11-10 上传
| 204 页
| 18.1 MB
| 9 阅读本文主要介绍 Flink Runtime 的作业执行的核心机制。首先介绍 Flink Runtime 的整体架构以及 Job 的基本执行流程,然后介绍在这个过程,Flink 是怎么进行资源管理、作业调度以及错误恢复的。最后,还将简要介绍 Flink Runtime 层当前正在进行的一些工作。
Flink是一款分布式的计算引擎,它可以用来做批处理,即处理静态的数据集、历史的数据集;也可以用来做流处理,即实时地处理一些实时数据流,实时地产生数据的结果;也可以用来做一些基于事件的应用,比如说滴滴通过Flink CEP实现实时监测用户及司机的行为流来判断用户或司机的行为是否正当。 总而言之,Flink是一个Stateful Computations Over Streams,即数据流上的有状态的计算。这里面有两个关键字,一个是Streams,Flink认为有界数据集是无界数据流的一种特例,所以说有界数据集也是一种数据流,事件流也是一种数据流。Everything is streams,即Flink可以用来处理任何的数据,可以支持批处理、流处理、AI、MachineLearning等等。
1 / 204
2 / 204
3 / 204
4 / 204
5 / 204
标签:Flink
温馨提示:
1.未经权益所有人同意不得将文件中的内容挪作商业或盈利用途;
2.本站仅提供存储空间,仅对用户上传内容作预览展示处理,对用户上传分享的文档内容本身不做任何修改或编辑,本站不对任何下载内容负责;
3.下载文件中如有侵权或不当内容,请与我们联系,我们立即纠正;
4.本站不保证下载资源的准确性、安全性和完整性,同时也不承担用户因使用这些下载资源对自己和他人造成任何形式的损失。
2.本站仅提供存储空间,仅对用户上传内容作预览展示处理,对用户上传分享的文档内容本身不做任何修改或编辑,本站不对任何下载内容负责;
3.下载文件中如有侵权或不当内容,请与我们联系,我们立即纠正;
4.本站不保证下载资源的准确性、安全性和完整性,同时也不承担用户因使用这些下载资源对自己和他人造成任何形式的损失。
最新评论
相关文章
Java大数据之Flink
Apache Flink是一个开源的分布式,高性能,高可用,准确的流处理框架。支持实时流处理和批处理。
五万字长篇-java虚拟机看这篇文章就够了(上)
五万字长篇内容详细介绍Java虚拟机,分为上、中、下三篇。
java stream实战:30个案例精通集合筛选、归约、分组与聚合操作
Stream API允许开发者以声明性方式处理数据集合。可以简化复杂的数据操作,并且支持并行处理以提高性能。
RxJava 2.0 有什么不同 (译)
这篇文章是对 RxJava 2.0 不同之处的介绍,包括重写遵循规范、新类型 Maybe 等的引入、基础接口变化、功能接口和操作符的命名与改动、Subscriber 改变、测试方法等诸多方面,还提及了移除的方法和组件以及其他改变。
OpenJDK1.8源码编译、调试
本文详细介绍了在Ubuntu14.04上编译OpenJDK1.8的过程,和使用VSCode进行远程调试JDK的步骤。
微信分享
另存到我的空间