explain (StreamingQuery)

Vytiskne plány (logické a fyzické) do konzoly pro ladění.

Syntaxe

explain(extended=False)

Parametry

Parameter Typ Description
extended bool, volitelné Pokud False (výchozí), vytiskne pouze fyzický plán. Pokud True, vytiskne analyzované, analyzované a optimalizované logické plány také.

Návraty

None

Příklady

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_explain').start()
sq.processAllAvailable()

Vytisknout pouze fyzický plán:

sq.explain()
# == Physical Plan ==
# ...

Vytisknout všechny plány:

sq.explain(True)
# == Parsed Logical Plan ==
# ...
# == Analyzed Logical Plan ==
# ...
# == Optimized Logical Plan ==
# ...
# == Physical Plan ==
# ...
sq.stop()