Spark. Sql. Streaming Namespace
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
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.