Flink 1.14从简单到源码第三讲

文章目录

• 1.flink多流操作Api
• • 1.1split 分流操作
  • 1.2.侧输出流
  • 1.3.connect 连接操作
  • 1.4.union 操作
  • 1.5 coGroup 协同分组
  • 1.6 join
  • 1.7 broadcast 广播
• 2.process
• 3.并行度和Api
• • 3.1 任务提交简单流程
  • 3.2 task与算子链
• 4. Flink 时间相关(窗口计算)
• • 4.1时间语义(窗口计算)
  • 4.2 新版api指定的时间语义
  • 4.3 watermark
  • 4.4 内置watermark 生成策略
  • 4.5 watermark 底层源码透析