Flink 之旅

Flink 之旅

Flink 之旅

• 有状态的流式处理
• • 传统数据处理架构
  • • 事务处理
    • 分析处理
  • 有状态的流式处理
  • 开源流处理的演进
  • Flink 简介
  • 编写第一个 Flink 程序
• 流处理基础
• Flink 运行架构

有状态的流式处理

Apache Flink 是一个分布式流处理器，具有直观和富有表现力的 API，可实现有状态的流处理应用程序。它以容错的方式有效地大规模运行这些应用程序

Flink 于 2014 年4 月加入 Apache 软件基金会作为孵化项目，并于 2015 年 1 月成为顶级项目。从一开始，Flink 就拥有一个非常活跃且不断增长的用户和贡献者社区

到目前为止，已有超过五百人为 Flink 做出贡献，并且它已经发展成为最复杂的开源流处理引擎之一，并得到了广泛采用的证明。

传统数据处理架构

企业实施的传统架构区分了两种类型的数据处理：

• 事务处理（OLTP）
• 分析处理（OLAP）

事务处理

公司将各种应用程序用于日常业务活动，例如企业资源规划（ERP）系统，客户关系管理（CRM）软件和基于 Web 的应用程序。这些系统通常设计有单独的层，用于数据处理（应用程序本身）和数据存储（事务数据库系统）

分析处理

有状态的流式处理

开源流处理的演进

Flink 简介 编写第一个 Flink 程序 流处理基础 Flink 运行架构