Question

本文内容适用范围：

• 2018.11.02 update, Spark 2.4 全系列 √ (已发布：2.4.0)
• 2018.02.28 update, Spark 2.3 全系列 √ (已发布：2.3.0 ~ 2.3.2)
• 2017.07.11 update, Spark 2.2 全系列 √ (已发布：2.2.0 ~ 2.2.3)

• 一、概述
  • 1.1 Structured Streaming 实现思路与实现概述
• 二、Sources 与 Sinks
  • 2.1 Structured Streaming 之 Source 解析
  • 2.2 Structured Streaming 之 Sink 解析
• 三、状态存储
  • 3.1 Structured Streaming 之状态存储解析
• 四、Event Time 与 Watermark
  • 4.1 Structured Streaming 之 Event Time 解析
  • 4.2 Structured Streaming 之 Watermark 解析