Megjegyzés
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhat bejelentkezni vagy módosítani a címtárat.
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhatja módosítani a címtárat.
Hibakeresési célból kinyomtatja a (logikai és fizikai) terveket a konzolon.
Szemantika
explain(extended: Optional[Union[bool, str]] = None, mode: Optional[str] = None)
Paraméterek
| Paraméter | Típus | Leírás |
|---|---|---|
extended |
bool, nem kötelező | alapértelmezett False. Ha False, csak a fizikai tervet nyomtatja ki. Ha ez a sztring nem adja meg a modebeállítást, akkor a mód megadásakor működik. |
mode |
str, nem kötelező | A tervek várható kimeneti formátumát adja meg.
simple: Csak fizikai terv nyomtatása.
extended: Logikai és fizikai tervek nyomtatása.
codegen: Kinyomtathat egy fizikai tervet és generált kódokat, ha elérhetők.
cost: Kinyomtathat egy logikai tervet és statisztikát, ha elérhetők.
formatted: Ossza fel a kimenetet két részre: egy fizikai terv vázlatára és a csomópont részleteire. |
Examples
df = spark.createDataFrame(
[(14, "Tom"), (23, "Alice"), (16, "Bob")], ["age", "name"])
df.explain()
# == Physical Plan ==
# *(1) Scan ExistingRDD[age...,name...]
df.explain(extended=True)
# == Parsed Logical Plan ==
# ...
# == Analyzed Logical Plan ==
# ...
# == Optimized Logical Plan ==
# ...
# == Physical Plan ==
# ...
df.explain(mode="formatted")
# == Physical Plan ==
# * Scan ExistingRDD (...)
# (1) Scan ExistingRDD [codegen id : ...]
# Output [2]: [age..., name...]
# ...