schema (DataSource)

Zwraca schemat źródła danych.

Może odwoływać się do dowolnego pola zainicjowanego w __init__ metodzie, aby wywnioskować schemat źródła danych, gdy użytkownicy nie określą go jawnie. Ta metoda jest wywoływana raz podczas wywoływania spark.read.format(...).load() metody w celu pobrania schematu dla operacji odczytu źródła danych. Jeśli ta metoda nie zostanie zaimplementowana, a użytkownik nie udostępni schematu podczas odczytywania źródła danych, zostanie zgłoszony wyjątek.

Składnia

schema()

Zwroty

StructType lub str

Schemat tego źródła danych lub ciąg DDL reprezentujący schemat.

Examples

Zwraca ciąg DDL:

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

Zwraca wartość :StructType

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