schema (DataSource)

Restituisce lo schema dell'origine dati.

Può fare riferimento a qualsiasi campo inizializzato nel __init__ metodo per dedurre lo schema dell'origine dati quando gli utenti non lo specificano in modo esplicito. Questo metodo viene richiamato una volta quando si chiama spark.read.format(...).load() per ottenere lo schema per un'operazione di lettura dell'origine dati. Se questo metodo non viene implementato e un utente non fornisce uno schema durante la lettura dell'origine dati, verrà generata un'eccezione.

Sintassi

schema()

Restituzioni

StructType oppure str

Schema di questa origine dati o stringa DDL che rappresenta lo schema.

Examples

Restituisce una stringa DDL:

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

Restituisce un oggetto StructType:

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