Microsoft.Spark.Sql.Streaming 命名空间

类

DataStreamReader	DataStreamReader 提供从外部存储系统加载流式处理 DataFrame 的功能 (例如文件系统、键值存储等) 。
DataStreamWriter	DataStreamWriter 提供将流式传输到 DataFrame 外部存储系统的功能 (例如文件系统、键值存储等) 。
StreamingQuery	新数据到达时在后台持续执行的查询句柄。
StreamingQueryException	停止 的 StreamingQuery异常。
StreamingQueryManager	一个类，用于管理 StreamingQuery 中的所有活动 。SparkSession
Trigger	用于指示 应由 生成结果的频率的策略 StreamingQuery

枚举

OutputMode

用于指定如何将流式处理数据帧的数据写入流式处理接收器的输出模式。