Spark Structed Streaming 入門詳解

一、概述 Structed Streaming 是一個可擴展和容錯能力構建與Spark Sql引擎上的流處理引擎。你可以像採用批次處理靜態數據一樣處理流式數據。隨着流數據的不斷流入，Sparksql引擎會增量的連續不斷的處理並且更新結果。可以使用DataSet/DataFrame的API進行 streaming aggregations, event-time windows, stream-to

>>阅读原文<<