expliquer (StreamingQuery)

Affiche les plans (logiques et physiques) dans la console pour le debugging.

Syntaxe

explain(extended=False)

parameter

parameter	Type	Description
extended	bool, facultatif	Si False (default), affiche uniquement le plan physique. Si True, affiche également les plans logiques analysés et optimisés.

parameter	Type	Description
extended	bool, facultatif	Si False (default), affiche uniquement le plan physique. Si True, affiche également les plans logiques analysés et optimisés.

Renvoie

None

Exemples

Python

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

Imprimer uniquement le plan physique :

Python

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

Afficher tous les plans :

Python

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