指定流式处理数据帧的数据如何写入流式处理接收器。
Syntax
outputMode(outputMode)
参数
| 参数 | 类型 | Description |
|---|---|---|
outputMode |
str | 输出模式。 选项为 append （仅新行）、 complete （每次更新的所有行）和 update （每次更新时仅更新的行;等效于 append 查询不包含聚合）。 |
退货
DataStreamWriter
示例
df = spark.readStream.format("rate").load()
df.writeStream.outputMode('append')
# <...streaming.readwriter.DataStreamWriter object ...>
使用 complete 模式打印聚合计数：
import time
df = spark.readStream.format("rate").option("rowsPerSecond", 10).load()
df = df.groupby().count()
q = df.writeStream.outputMode("complete").format("console").start()
time.sleep(3)
q.stop()