explain (StreamingQuery)

Drukuje plany (logiczne i fizyczne) w konsoli na potrzeby debugowania.

Składnia

explain(extended=False)

Parametry

Parameter Typ Opis
extended wartość logiczna, opcjonalnie Jeśli False (ustawienie domyślne), drukuje tylko plan fizyczny. Jeśli Trueprogram wyświetla również przeanalizowane, przeanalizowane i zoptymalizowane plany logiczne.

Zwroty

None

Examples

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

Wydrukuj tylko plan fizyczny:

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

Drukuj wszystkie plany:

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