schéma (Zdroj dat)

Vrátí schéma zdroje dat.

Může odkazovat na jakékoli pole inicializované v __init__ metodě, aby odvodil schéma zdroje dat, když uživatelé explicitně nezadají. Tato metoda se vyvolá jednou při volání spark.read.format(...).load() pro získání schématu pro operaci čtení zdroje dat. Pokud tato metoda není implementována a uživatel neposkytuje schéma při čtení zdroje dat, vyvolá se výjimka.

Syntaxe

schema()

Návraty

StructType nebo str

Schéma tohoto zdroje dat nebo řetězec DDL představující schéma

Příklady

Vrátí řetězec DDL:

def schema(self):
    return "a INT, b STRING"

StructTypeVrátí :

def schema(self):
    return StructType().add("a", "int").add("b", "string")