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.