Microsoft.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.

A class to manage all the StreamingQuery active in a SparkSession.

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.