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



