大数据-玩转数据-Spark-Structured Streaming 输出 *** 作（python版）

大数据-玩转数据-Spark-Structured Streaming 输出 *** 作（python版） 大数据-玩转数据-Spark-Structured Streaming 输出 *** 作（python版）

1、说明
Structured Streaming流计算过程定义的Dataframe/Dataset结果，通过writeStream()方法写入到输出接收器，接收器对应关系如下：

接收器 支持输出模式 File接收器 Append Kafka接收器 Append、Complete、Update Foreach接收器 Append、Complete、Update Console接收器 Append、Complete、Update Memory接收器 Append、Complete

writeStream()方法包括以下几个主要函数
format : 接收器类型
outputMode ：输出模式
queryName ：查询名称
trigger ：触发间隔时间

2、socket输入File接收append模式代码

vi kafkastructuredwordCountresultsave1.py