jelaskan (StreamingQuery)

Mencetak paket (logis dan fisik) ke konsol untuk penelusuran kesalahan.

Sintaksis

explain(extended=False)

Parameter-parameternya

Parameter	Tipe	Deskripsi
extended	bool, opsional	Jika False (default), hanya mencetak paket fisik. Jika True, mencetak rencana logis yang diurai, dianalisis, dan dioptimalkan juga.

Pengembalian Barang

None

Examples

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

Cetak paket fisik saja:

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

Cetak semua paket:

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