掌握Flink基础教程

文章结构概述

• 第1章 选择Flink的原因

  • 第2章 流式数据处理架构

    • • 2.2 消息传递层与流处理层

      • 2.3 消息传输层应具备的理想特性

        • 2.3.1 兼具高效性与数据持久化能力
          • 2.3.2 实现生产者与消费者之间的解耦操作

      • 2.4 支持微服务架构的流式数据处理

        • 2.4.1 将数据流作为核心的数据来源

  • 第4章 时间维度的处理机制

    • • 4.1 批处理架构与Lambda架构的应用方式

      • 4.2 流处理架构的应用方式

      • 4.3 时间概念的定义与应用

      • 4.4 窗口机制的实现方式

        • 4.4.1 基于时间划分的窗口类型
          • 4.4.2 基于事件数量划分的窗口类型
          • 4.4.3 基于会话行为划分的窗口类型
          • 4.4.4 触发窗口计算的操作机制
          • 4.4.5 窗口功能的具体实现方法

      • 4.5 时间回溯技术的应用场景

      • 4.6 水印机制的设计原理

  • 第5章 具备状态管理能力的计算模式

    • • 5.2 检查点：确保精确一次的数据处理特性
      • 5