StructuredStreaming

一，概述 Structured Streaming是一個可擴展和容錯的流處理引擎，並且是構建於sparksql引擎之上。你可以用處理靜態數據的方式去處理你的流計算。隨着流數據的不斷流入，Sparksql引擎會增量的連續不斷的處理並且更新結果。可以使用DataSet/DataFrame的API進行 streaming aggregations, event-time windows, stream-

>>阅读原文<<