Core Classes

DataStreamReader (spark)	用于从外部存储系统加载流式 DataFrame 的接口（例如
DataStreamWriter (df)	用于将流式 DataFrame 写入外部存储系统（例如
StreamingQuery (jsq)	一个指向正在后台持续执行的查询的句柄，随着新数据的到达。
StreamingQueryManager (jsqm)	一个用于管理所有活动的 StreamingQuery 的类。
StreamingQueryListener	用于监听与 StreamingQuery 相关的事件的接口。

上一篇

结构化流

下一页

pyspark.sql.streaming.数据流读取器