expliquer (StreamingQuery)

Imprime les plans (logiques et physiques) dans la console pour le débogage.

Syntaxe

explain(extended=False)

Paramètres

Paramètre Type Description
extended bool, facultatif Si False (valeur par défaut), imprime uniquement le plan physique. Si True, imprime également les plans logiques analysés, analysés et optimisés.

Retours

None

Exemples

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

Imprimez le plan physique uniquement :

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

Imprimer tous les plans :

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