本文非常之长,但是文章内容深度极佳,深度剖析了Stream SQL的原理和在Flink中的实践。建议大家挑个时间认...[作者空间]
一、历史变迁 在Flink 1.0.0时期 提供了RocksDB的支持,这个版本之前所有的状态都只能存在进程的内存...[作者空间]
前言 对于流计算来说,最核心的概念就是无穷数据集,而用来处理无穷数据集的计算就可以称为流计算。面对无穷数据集,有多...[作者空间]
Scheduling 1、Flink的Execution resources是通过Task Slots定义的。每个...[作者空间]
概述 就像我们所知道的,Flink采用了自己管理内存的方式,或者说积极的内存管理,而MemorySegment就是...[作者空间]
基本原则 https://cwiki.apache.org/confluence/display/FLINK/Da...[作者空间]
一、概述 数据局部性是Flink中的一个关键原则,并且强烈影响状态的存储和访问方式。Flink中的状态都是Loca...[作者空间]
一、概述 Flink's distributed execution consists of two import...[作者空间]
一、Physical partitioning 在一个transformation之后,Flink也提供了底层AP...[作者空间]