Structured Streaming编程模型

Structured Streaming 的核心思想是将实时数据流看作数据在不断追加的表。这种思想促生了一种新的，和批处理模型非常类似的流处理模型。您可以像表示静态数据标准批查询一样表示流计算。Spark 会在这个无界表上运行增量查询。 目录 1. 基本概念 2. 事件时间和迟到数据处理 3. 容错机制 1. 基本概念 如果把输入流看作是“Input Table”，那么流中到达的每个数据元素都像是

>>阅读原文<<