Flink 之旅

  • 2022-01-04
  • Admin

有状态的流式处理

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

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

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

传统数据处理架构

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

  • 事务处理(OLTP)
  • 分析处理(OLAP)

事务处理

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

在这里插入图片描述

在这里插入图片描述

分析处理

在这里插入图片描述

有状态的流式处理

在这里插入图片描述

开源流处理的演进

在这里插入图片描述

Flink 简介

编写第一个 Flink 程序

流处理基础

Flink 运行架构

原文:https://blog.csdn.net/qq_44226094/article/details/122313111

联系站长

QQ:769220720