[TOC] 一. 状态管理的基本概念 首先举一个无状态计算的例子：消费延迟计算。假设现在有一个消息队列，消息队列中有一个生产者持续往消费队列写入...

我们将探讨一个 Flink 作业在实际运行时，不同的 Task 之间是如何进行数据交换的。由于不同的 Task 可能并非运行在同一个 TaskM...

[TOC] 如何理解flink中state(状态) state泛指 state泛指：flink中有状态函数和运算符在各个元素(element)/...

[TOC] Dataflow 图 顾名思义， Dataflow 程序描述了数据如何在不同操作之间流动。 Dataflow 程序通常表示为有向图。...

[TOC]Flink的Transformation转换主要包括四种：单数据流基本转换、基于Key的分组转换、多数据流转换和数据重分布转换。本文主...

[TOC]Data Sources 是什么呢？就字面意思其实就可以知道：数据来源。 Flink 做为一款流式计算框架，它可用来做批处理，即处理静...

[TOC]来源于http://www.54tianzhisheng.cn/2018/10/13/flink-introduction/[http...