Microsoft.Spark.Sql.Streaming Namespace

Classes

DataStreamReader	DataStreamReader provides functionality to load a streaming DataFrame from external storage systems (e.g. file systems, key-value stores, etc).
DataStreamWriter	DataStreamWriter provides functionality to write a streaming DataFrame to external storage systems (e.g. file systems, key-value stores, etc).
StreamingQuery	A handle to a query that is executing continuously in the background as new data arrives.
StreamingQueryException	Exception that stopped a StreamingQuery.
StreamingQueryManager	A class to manage all the StreamingQuery active in a SparkSession.
Trigger	Policy used to indicate how often results should be produced by a StreamingQuery

Enums

OutputMode

Output modes for specifying how data of a streaming DataFrame is written to a streaming sink.