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() 以便再次用來等候新的終止