Core Classes

DataStreamReader(spark)	Interface used to load a streaming DataFrame from external storage systems (e.g.
DataStreamWriter(df)	Interface used to write a streaming DataFrame to external storage systems (e.g.
StreamingQuery(jsq)	A handle to a query that is executing continuously in the background as new data arrives.
StreamingQueryManager(jsqm)	A class to manage all the StreamingQuery StreamingQueries active.
StreamingQueryListener	Interface for listening to events related to StreamingQuery.

previous

Structured Streaming

next

pyspark.sql.streaming.DataStreamReader