Flink使用教程

目录

• 环境（Environment）

• 源（Source）
  2.1 通过内存进行数据获取
  2.2 基于文件系统进行数据获取
  2.3 使用kafka协议进行流式数据分析处理
  2.4 通过网络接口接收来自外部的数据流
  自定义环境下的特殊处理

  • 3、Transform
  • • 3.1 map
    • • 3.1.1 MapFunction
      • 3.1.2 RichMapFunction

• 平坦合并操作 (flatMap)

• 筛选操作 (filter)

• 键提取操作 (keyBy)

• 洗牌操作 (shuffle)

• 拆分与选择操作 (split + select)

• 连接操作 (connect)

• 合并操作 (union)

• Operator

  • 滚动聚合算子（Rolling Aggregation）

    • 累加操作 (reduce)
    • 处理流程 (process)

  • 4、Sink

Flink开发大致分为四个阶段：工作环境（Environment）、数据源（Source）、转换操作（Transform）、处理结果（Sink）。 创建一个基于Maven的项目，并配置pom文件以添加依赖项。