Structured Streaming-编程模型

Structured Streaming的关键思想在于将实时数据流视为不断追加的表。这导致与批处理模型非常相似的流处理模型。我们可以在静态表上将流式计算表示为标准的batch-like查询，而Spark会在无界输入表上作为增量查询来运行它。 一 基本概念 将输入数据流视为“输入表”，到达流的每个数据项都像追加到输入表的新的一行。 对输入的查询将生成“结果表”。 每个触发间隔（例如：每1秒），新行将

>>阅读原文<<