Spark Structured Streaming框架(2)之數據輸入源詳解

　　Spark Structured Streaming目前的2.1.0版本只支持輸入源：File、kafka和socket。 1. Socket 　　Socket方式是最簡單的數據輸入源，如Quick example所示的程序，就是使用的這種方式。用戶只需要指定"socket"形式並配置監聽的IP和Port即可。 val scoketDF = spark.readStream .format("

>>阅读原文<<