Structured Streaming-編程模型

Structured Streaming的關鍵思想在於將實時數據流視爲不斷追加的表。這導致與批處理模型非常相似的流處理模型。我們可以在靜態表上將流式計算表示爲標準的batch-like查詢，而Spark會在無界輸入表上作爲增量查詢來運行它。 一 基本概念 將輸入數據流視爲「輸入表」，到達流的每個數據項都像追加到輸入表的新的一行。 對輸入的查詢將生成「結果表」。 每個觸發間隔（例如：每1秒），新行將

>>阅读原文<<