5. 时间和窗口

• 5.1. Flink 的时间语义
  • Flink 的三种时间语义
    • Event Time
    • Processing Time
    • Ingestion Time
  • 设置时间语义
  • Event Time 和 Watermark
  • 分布式环境下 Watermark 的传播
  • 抽取时间戳及生成 Watermark
    • Source
    • Source 之后
      • Periodic
      • Punctuated
  • 平衡延迟和准确性
• 5.2. ProcessFunction
  • Timer 的使用方法
  • 侧输出
  • 在两个流上使用 ProcessFunction {#process-on-two-streams}
• 5.3. 窗口算子
  • 窗口程序的骨架
  • 内置的三种窗口划分方法
    • 滚动窗口
    • 滑动窗口
    • 会话窗口
  • 窗口函数
    • ReduceFunction
    • AggregateFunction {#aggregate-function}
    • ProcessWindowFunction
    • ProcessWindowFunction 与增量计算相结合
  • 拓展和自定义窗口
    • Trigger
    • Evictor
• 5.4. 双流关联
  • Window Join
  • Interval Join
• 5.5. 迟到数据
  • 将迟到数据丢弃
  • 将迟到数据发送到另外一个流
  • 更新计算结果
• 5.6. 案例实战：股票价格
  • 实验目的
  • 实验内容
  • 实验要求
  • 实验报告