uitleggen (StreamingQuery)

Hiermee worden de (logische en fysieke) plannen afgedrukt naar de console voor foutopsporing.

Syntaxis

explain(extended=False)

Parameterwaarden

Kenmerk Typ Beschrijving
extended bool, optioneel Als False (standaard) alleen het fysieke plan wordt afgedrukt. Als True, worden ook de geparseerde, geanalyseerde en geoptimaliseerde logische plannen afgedrukt.

Retouren

None

Examples

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

Alleen het fysieke plan afdrukken:

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

Alle plannen afdrukken:

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