объяснить (StreamingQuery)

Выводит планы (логические и физические) в консоль для отладки.

Синтаксис

explain(extended=False)

Параметры

Параметр	Тип	Описание
extended	bool, необязательный	Если False (по умолчанию) выводит только физический план. Если True, печатает проанализированные, проанализированные и оптимизированные логические планы.

Возвраты

None

Примеры

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

Печать только физического плана:

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

Печать всех планов:

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