核心類

DataStreamReader(火花)	接口用於加載一個流DataFrame從外部存儲係統(如。
DataStreamWriter(df)	接口用於編寫一個流DataFrame(如外部存儲係統。
StreamingQuery(jsq)	處理一個查詢是在後台執行不斷新數據到來。
StreamingQueryManager(jsqm)	一個類來管理的StreamingQueryStreamingQueries活躍。
StreamingQueryListener	界麵聽相關的事件StreamingQuery。

以前的

結構化流

下一個

pyspark.sql.streaming.DataStreamReader