förklara (StreamingQuery)

Skriver ut (logiska och fysiska) planer till konsolen för felsökning.

Syntax

explain(extended=False)

Parameters

Parameter Type Beskrivning
extended bool, valfritt Om False (standard) skriver endast ut den fysiska planen. Om Trueskriver ut de tolkade, analyserade och optimerade logiska planerna också.

Retur

None

Exempel

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

Skriv endast ut den fysiska planen:

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

Skriv ut alla abonnemang:

sq.explain(True)
# == Parsed Logical Plan ==
# ...
# == Analyzed Logical Plan ==
# ...
# == Optimized Logical Plan ==
# ...
# == Physical Plan ==
# ...
sq.stop()
  • Last updated on