pyspark.sql.streaming.DataStreamWriter.outputMode¶
-
DataStreamWriter。outputMode( outputMode:str )→pyspark.sql.streaming.readwriter.DataStreamWriter¶ -
指定數據流DataFrame /數據集是如何寫入到流水槽。
選項包括:
-
- 附加:隻有新行流DataFrame /數據集將被寫入
-
水槽
-
- 完整的:所有的行流DataFrame /數據集將被寫入到水槽裏
-
每次有更新
-
- 更新:隻有更新的行流DataFrame /數據集
-
每次寫入水槽有一些更新。如果查詢不包含聚合,它將相當於附加模式。
筆記
這個API是不斷發展的。
例子
> > >作家=自衛隊。writeStream。outputMode(“添加”)
-