DataStreamReader(spark)
|
Interface used to load a streaming DataFrame from external storage systems (e.g. file systems, key-value stores, etc). |
DataStreamWriter(df)
|
Interface used to write a streaming DataFrame to external storage systems (e.g. file systems, key-value stores, etc). |
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. |
