schema (DataSource)

Returnerar datakällans schema.

Det kan referera till alla fält som initieras i __init__ metoden för att härleda datakällans schema när användarna inte uttryckligen anger det. Den här metoden anropas en gång när du anropar spark.read.format(...).load() för att hämta schemat för en läsåtgärd för en datakälla. Om den här metoden inte implementeras och en användare inte tillhandahåller något schema när han eller hon läser datakällan utlöses ett undantag.

Syntax

schema()

Retur

StructType eller str

Schemat för den här datakällan eller en DDL-sträng som representerar schemat.

Exempel

Returnerar en DDL-sträng:

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

Returnerar en StructType:

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