Structured Streaming Programming Guide

概述 結構化流是一種基於Spark SQL引擎的可擴展且容錯的流處理引擎。他可以像表達靜態數據的批處理計算一樣表達流式計算。 快速示例 監聽本地netcat服務器的輸入內容 實時計算每個單詞出現的次數在屏幕上打印 可以通過運行下載的Spark目錄下的程序直接啓動 再另外啓動一個netcat服務器 再服務器終端輸入內容即可在控制檯看見相應的輸出 編程模型 結構化流中的關鍵思想是將實時數據流視爲連續追
相關文章
相關標籤/搜索