Spark. Sql. Streaming Namespace
DataStreamReader provides functionality to load a streaming DataFrame from external storage systems (e.g. file systems, key-value stores, etc).
DataStreamWriter provides functionality to write a streaming DataFrame to external storage systems (e.g. file systems, key-value stores, etc).
A handle to a query that is executing continuously in the background as new data arrives.
Exception that stopped a StreamingQuery.
Policy used to indicate how often results should be produced by a StreamingQuery
Output modes for specifying how data of a streaming DataFrame is written to a streaming sink.