Structured Streaming 是一個可拓展，容錯的，基于Spark SQL執行引擎的流處理引擎。使用小量的靜態數據模擬流處理。伴隨流數據的到來，Spark SQL引擎會逐漸連續處理數據并且更新結果到最終的Table中。你可以在Spark SQL上引擎上使用DataSet/DataFrame API處理流數據的聚集，事件窗口，和流與批次的連接操作等。最后Structured Streaming 系統快速，穩定，端到端的恰好一次保證，支持容錯的處理。