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.

Structured Streaming pyspark.sql.streaming.DataStreamReader