【秒懂StructuredStreaming】手把手教你寫StructuredStreaming + Kafka程序

這篇博客我們介紹基於StructuredStreaming進行實時流算子開發，並將結果輸出到kafka中。       StructuredStreaming使用的數據類型是DataFrame和Dataset。      從Spark 2.0開始，DataFrame和Dataset可以表示靜態（有界數據），以及流式（無界數據）。與靜態Dataset/ DataFrame類似，用戶可以使用公共入口點

>>阅读原文<<