explain (StreamingQuery)

Hata ayıklama için (mantıksal ve fiziksel) planları konsola yazdırır.

Sözdizimi

explain(extended=False)

Parametreler

Parametre Türü Açıklama
extended bool, isteğe bağlı If False (varsayılan), yalnızca fiziksel planı yazdırır. ise Trueayrıştırılmış, analiz edilmiş ve iyileştirilmiş mantıksal planları da yazdırır.

İadeler

None

Örnekler

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

Yalnızca fiziksel planı yazdırın:

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

Tüm planları yazdır:

sq.explain(True)
# == Parsed Logical Plan ==
# ...
# == Analyzed Logical Plan ==
# ...
# == Optimized Logical Plan ==
# ...
# == Physical Plan ==
# ...
sq.stop()
  • Last updated on