StreamingQueryManager 类

定义

命名空间:

Microsoft.Spark.Sql.Streaming

程序集:

Microsoft.Spark.dll

包:

Microsoft.Spark v1.0.0

一个类， StreamingQuery 用于管理 中 SparkSession所有活动的 。

public sealed class StreamingQueryManager

type StreamingQueryManager = class

Public NotInheritable Class StreamingQueryManager

继承

Object

StreamingQueryManager

方法

Active()	返回与此 SQLContext 关联的活动查询的列表。
AwaitAnyTermination()	请等待，直到关联 SQLContext 上的任何查询自创建上下文后终止，或自调用后 ResetTerminated() 终止。 如果任何查询因异常而终止，则会引发异常。 如果查询已终止，则对 的后续调用 AwaitAnyTermination() 将立即返回 (如果查询被 Stop()) 终止，或者如果查询终止并出现异常) ，则立即引发异常 (。 使用 ResetTerminated() 清除过去的终止并等待新的终止。 如果多个查询自调用以来 ResetTerminated() 已终止，则如果任何查询已以异常终止，则会 AwaitAnyTermination() 引发任何异常。 若要正确记录多个查询中的异常，用户需要在其中任何异常终止后停止所有这些查询，然后检查 Exception() 每个查询的 。 如果任何查询已终止并出现异常，则会在 JVM 上引发 StreamingQueryException。
AwaitAnyTermination(Int64)	请等待，直到关联 SQLContext 上的任何查询自创建上下文后终止，或自调用后 ResetTerminated() 终止。 如果任何查询因异常而终止，则会引发异常。 如果查询已终止，则对 的后续调用 AwaitAnyTermination() 将立即返回 (如果查询被 Stop()) 终止，或者如果查询终止并出现异常) ，则立即引发异常 (。 使用 ResetTerminated() 清除过去的终止并等待新的终止。 如果多个查询自调用以来 ResetTerminated() 已终止，则如果任何查询已以异常终止，则会 AwaitAnyTermination() 引发任何异常。 若要正确记录多个查询中的异常，用户需要在其中任何异常终止后停止所有这些查询，然后检查 Exception() 每个查询的 。 如果任何查询已终止并出现异常，则会在 JVM 上引发 StreamingQueryException。
Get(String)	从此 SQLContext 返回活动查询，如果不存在具有此名称的活动查询，则引发异常。
ResetTerminated()	忘记过去终止的查询， AwaitAnyTermination() 以便可以再次使用该查询来等待新的终止