StreamingQuery Třída

Definice

Obor názvů:

Microsoft.Spark.Sql.Streaming

Sestavení:

Microsoft.Spark.dll

Balíček:

Microsoft.Spark v1.0.0

Popisovač dotazu, který se průběžně spouští na pozadí při příchodu nových dat.

public sealed class StreamingQuery

type StreamingQuery = class

Public NotInheritable Class StreamingQuery

Dědičnost

Object

StreamingQuery

Vlastnosti

Id	Vrátí jedinečné ID tohoto dotazu, které se zachová při restartování z dat kontrolního bodu. To znamená, že toto ID se vygeneruje při prvním spuštění dotazu a bude stejné při každém restartování z dat kontrolního bodu. Další informace najdete v tématu RunId.
Name	Vrátí název dotazu zadaný uživatelem, nebo hodnotu null, pokud není zadaný.
RunId	Vrátí jedinečné ID tohoto spuštění dotazu. To znamená, že při každém spuštění nebo restartování dotazu se vygeneruje jedinečné ID spuštění. Proto pokaždé, když se dotaz restartuje z kontrolního bodu, bude mít stejné Id , ale odlišné RunIds.

Metody

AwaitTermination()	Čeká na ukončení tohoto dotazu, a to buď příkazem Stop(), nebo výjimkou.
AwaitTermination(Int64)	Vrátí hodnotu true, pokud je tento dotaz ukončen v rámci časového limitu v milisekundách.
Exception()	Pokud StreamingQueryException byl dotaz ukončen výjimkou, v opačném případě hodnota null.
Explain(Boolean)	Vytiskne fyzický plán do konzoly pro účely ladění.
IsActive()	Vrátí hodnotu true, pokud je tento dotaz aktivně spuštěný.
ProcessAllAvailable()	Blokuje, dokud nebudou všechna dostupná data ve zdroji zpracována a potvrzena do jímky. Tato metoda je určená pro testování. Upozorňujeme, že v případě nepřetržitě přicházejících dat může tato metoda trvale blokovat. Kromě toho je tato metoda garantována pouze blokování, dokud data, která byla synchronně připojena data před org.apache.spark.sql.execution.streaming.Source vyvoláním. (tj. getOffset musí okamžitě odrážet sčítání).
Stop()	Zastaví provádění tohoto dotazu, pokud je spuštěný. Tato metoda blokuje, dokud vlákna provádějící zastavení provádění.