(ストリーミングクエリ)を説明する
デバッグのために、(論理プランと物理プランの)内容をコンソールに出力します。
構文
explain(extended=False)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
| ブール値、オプション |
|
戻り値
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()