schema (DataSource)

Возвращает схему источника данных.

Он может ссылаться на любое поле, инициализированное в методе __init__ , чтобы определить схему источника данных, если пользователи не явно указывают ее. Этот метод вызывается один раз при вызове spark.read.format(...).load() для получения схемы для операции чтения источника данных. Если этот метод не реализован, и пользователь не предоставляет схему при чтении источника данных, создается исключение.

Синтаксис

schema()

Возвраты

StructType или str

Схема этого источника данных или строка DDL, представляющая схему.

Примеры

Возвращает строку DDL:

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

StructTypeВозвращает :

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