explain (StreamingQuery)

Imprime los planes (lógicos y físicos) en la consola para la depuración.

Sintaxis

explain(extended=False)

Parámetros

Parámetro Tipo Descripción
extended bool, opcional Si False es (valor predeterminado), imprime solo el plan físico. Si Truees , imprime también los planes lógicos analizados, analizados y optimizados.

Devoluciones

None

Ejemplos

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

Imprima solo el plan físico:

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

Imprimir todos los planes:

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