Schema (DataSource)

Gibt das Schema der Datenquelle zurück.

Sie kann auf jedes Feld verweisen, das in der __init__ Methode initialisiert wurde, um das Schema der Datenquelle zu ableiten, wenn Benutzer es nicht explizit angeben. Diese Methode wird beim Aufrufen spark.read.format(...).load() des Schemas für einen Datenquellenlesevorgang einmal aufgerufen. Wenn diese Methode nicht implementiert ist und ein Benutzer beim Lesen der Datenquelle kein Schema bereitstellt, wird eine Ausnahme ausgelöst.

Syntax

schema()

Rückkehr

StructType oder str

Das Schema dieser Datenquelle oder eine DDL-Zeichenfolge, die das Schema darstellt.

Beispiele

Gibt eine DDL-Zeichenfolge zurück:

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

Gibt ein StructType:

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