理解Spark中Structed SparkStreaming概念與使用

1.Overview 結構化流是一種基於Spark SQL引擎的可擴展且容錯的流處理引擎。 您可以像表達靜態數據的批處理計算一樣表達流式計算。 Spark SQL引擎將負責逐步和連續地運行它，並在流數據繼續到達時更新最終結果。 您可以使用Scala，Java，Python或R中的數據集/數據框架API來表示流聚合，事件時間窗口，流到批處理連接等。 計算在同一優化的Spark SQL引擎上執行。 最

>>阅读原文<<