schema (DataSource)

Retourneert het schema van de gegevensbron.

Het kan verwijzen naar elk veld dat in de __init__ methode is geïnitialiseerd om het schema van de gegevensbron af te leiden wanneer gebruikers dit niet expliciet opgeven. Deze methode wordt eenmaal aangeroepen wanneer u aanroept spark.read.format(...).load() om het schema voor een leesbewerking voor een gegevensbron op te halen. Als deze methode niet is geïmplementeerd en een gebruiker geen schema biedt bij het lezen van de gegevensbron, wordt er een uitzondering gegenereerd.

Syntaxis

schema()

Retouren

StructType of str

Het schema van deze gegevensbron of een DDL-tekenreeks die het schema vertegenwoordigt.

Examples

Hiermee wordt een DDL-tekenreeks geretourneerd:

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

Retourneert een StructType:

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