StreamingQuery

Popisovač dotazu, který se spouští nepřetržitě na pozadí při příchodu nových dat. Všechny metody jsou bezpečné pro přístup z více vláken.

Syntaxe

# Returned by DataStreamWriter.start() or DataStreamWriter.toTable()
q = df.writeStream.format("console").start()

Vlastnosti

Vlastnictví	Description
id	Vrátí jedinečné ID tohoto dotazu, které se zachová napříč restartováními z dat kontrolního bodu.
runId	Vrátí jedinečné ID tohoto dotazu, které se nezachovává při restartování.
name	Vrátí uživatelem zadaný název dotazu nebo None pokud není zadaný.
isActive	Vrátí, zda je tento streamovací dotaz aktuálně aktivní.
status	Vrátí aktuální stav dotazu jako diktování.
recentProgress	Vrátí pole nejnovějších StreamingQueryProgress aktualizací pro tento dotaz.
lastProgress	Vrátí nejnovější StreamingQueryProgress aktualizaci nebo None pokud nedošlo k žádným aktualizacím.

Methods

Metoda	Description
awaitTermination(timeout)	Čeká na ukončení tohoto dotazu, a to buď výjimkou stop() , nebo výjimkou.
processAllAvailable()	Blokuje, dokud nebudou všechna dostupná data ve zdroji zpracována a potvrzena do jímky. Určeno pro testování.
stop()	Zastaví tento dotaz streamování.
explain(extended)	Vytiskne plány (logické a fyzické) do konzoly pro ladění.
exception()	StreamingQueryException Vrátí dotaz, pokud byl dotaz ukončen s výjimkou, nebo None.

Příklady

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq.isActive
# True
sq.name
# 'this_query'
sq.awaitTermination(5)
# False
sq.stop()
sq.isActive
# False