メインコンテンツまでスキップ

(ストリーミングクエリ)を説明する

デバッグのために、(論理プランと物理プランの)内容をコンソールに出力します。

構文

explain(extended=False)

パラメーター

パラメーター

Type

説明

extended

ブール値、オプション

False (デフォルト)の場合、物理プランのみを出力します。Trueの場合、解析、分析、最適化された論理プランも出力されます。

戻り値

None

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

平面図のみを印刷する:

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

すべての図面を印刷する:

Python
sq.explain(True)
# == Parsed Logical Plan ==
# ...
# == Analyzed Logical Plan ==
# ...
# == Optimized Logical Plan ==
# ...
# == Physical Plan ==
# ...
sq.stop()
このページの見出し