explicar (StreamingQuery)
Imprime os planos (lógicos e físicos) no console para depuração.
Sintaxe
explain(extended=False)
Parâmetros
Parâmetro | Tipo | Descrição |
|---|---|---|
| booleano, opcional | Se |
Devoluções
None
Exemplos
Python
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_explain').start()
sq.processAllAvailable()
Imprima apenas a planta física:
Python
sq.explain()
# == Physical Plan ==
# ...
Imprimir todos os planos:
Python
sq.explain(True)
# == Parsed Logical Plan ==
# ...
# == Analyzed Logical Plan ==
# ...
# == Optimized Logical Plan ==
# ...
# == Physical Plan ==
# ...
sq.stop()