explain (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()