Structured Streaming《入門示例》

  概述： Structured Streaming 是一個構建在Spark SQL 引擎上，可擴展，容錯的的流處理引擎。您能夠像編寫靜態數據的批處理程序同樣，編寫流處理程序。Spark SQL 引擎會增量的運行流處理程序，並持續的，在有流數據到來時更新最終結果。您可使用DataSet/DataFrame API 來編寫流聚合、事件窗口、流和批 join等操做（目前支持Scala,Java，Pyt

>>阅读原文<<