StreamingQueryManager Třída

Reference

Definice

Obor názvů:: Microsoft.Spark.Sql.Streaming

Sestavení:: Microsoft.Spark.dll

Balíček:: Microsoft.Spark v1.0.0

Důležité

Některé informace platí pro předběžně vydaný produkt, který se může zásadně změnit, než ho výrobce nebo autor vydá. Microsoft neposkytuje žádné záruky, výslovné ani předpokládané, týkající se zde uváděných informací.

Třída pro správu všech aktivních StreamingQuery v objektu SparkSession.

public sealed class StreamingQueryManager

type StreamingQueryManager = class

Public NotInheritable Class StreamingQueryManager

Dědičnost: Object
StreamingQueryManager

Metody

Active()	Vrátí seznam aktivních dotazů přidružených k tomuto SQLContext.
AwaitAnyTermination()	Počkejte, až se některý z dotazů na přidruženém SQLContext ukončí od vytvoření kontextu nebo od doby, kdy ResetTerminated() byl volána. Pokud byl některý dotaz ukončen s výjimkou, vyvolá se výjimka. Pokud se dotaz ukončil, pak se následná volání AwaitAnyTermination() vrátí buď okamžitě (pokud byl dotaz ukončen pomocí Stop()), nebo vyvolá výjimku okamžitě (pokud byl dotaz ukončen s výjimkou). Slouží ResetTerminated() k vymazání předchozích ukončení a čekání na nová ukončení. V případě, že se od ResetTerminated() zavolání ukončilo více dotazů, pokud se některý dotaz ukončil s výjimkou, AwaitAnyTermination() vyvolá některou z výjimek. Aby bylo možné správně zdokumentovat výjimky napříč několika dotazy, musí je uživatelé po ukončení některého z nich s výjimkou zastavit a pak zkontrolovat Exception() pro každý dotaz. Vyvolá výjimku StreamingQueryException na JVM, pokud se některý dotaz ukončil s výjimkou.
AwaitAnyTermination(Int64)	Počkejte, až se některý z dotazů na přidruženém SQLContext ukončí od vytvoření kontextu nebo od doby, kdy ResetTerminated() byl volána. Pokud byl některý dotaz ukončen s výjimkou, vyvolá se výjimka. Pokud se dotaz ukončil, pak se následná volání AwaitAnyTermination() vrátí buď okamžitě (pokud byl dotaz ukončen pomocí Stop()), nebo vyvolá výjimku okamžitě (pokud byl dotaz ukončen s výjimkou). Slouží ResetTerminated() k vymazání předchozích ukončení a čekání na nová ukončení. V případě, že se od ResetTerminated() zavolání ukončilo více dotazů, pokud se některý dotaz ukončil s výjimkou, AwaitAnyTermination() vyvolá některou z výjimek. Aby bylo možné správně zdokumentovat výjimky napříč několika dotazy, musí je uživatelé po ukončení některého z nich s výjimkou zastavit a pak zkontrolovat Exception() pro každý dotaz. Vyvolá výjimku StreamingQueryException na JVM, pokud se některý dotaz ukončil s výjimkou.
Get(String)	Vrátí aktivní dotaz z tohoto SQLContext nebo vyvolá výjimku, pokud aktivní dotaz s tímto názvem neexistuje.
ResetTerminated()	Zapomeňte na předchozí ukončené dotazy, AwaitAnyTermination() abyste je mohli znovu použít k čekání na nová ukončení.

Platí pro