Compartilhar via

explain (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
extended bool, opcional Se False (padrão), imprimirá apenas o plano físico. Se True, imprime os planos lógicos analisados, analisados e otimizados também.

Devoluções

None

Exemplos

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

Imprima somente o plano físico:

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

Imprima todos os planos:

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