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("

>>阅读原文<<