Freigeben über


erklären (StreamingQuery)

Druckt die Pläne (logische und physische) für das Debuggen in der Konsole.

Syntax

explain(extended=False)

Parameter

Parameter Typ Beschreibung
extended bool, optional Wenn False (Standard) wird nur der physische Plan gedruckt. Wenn True, druckt auch die analysierten, analysierten und optimierten logischen Pläne.

Rückkehr

None

Beispiele

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

Drucken Sie nur den physischen Plan:

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

Alle Pläne drucken:

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