schema

Указывает входную схему. Некоторые источники данных (например, JSON) могут автоматически выводить входную схему из данных. Указав схему здесь, базовый источник данных может пропустить шаг вывода схемы, который ускоряет загрузку данных.

Синтаксис

schema(schema)

Параметры

Параметр	Тип	Описание
schema	StructType или str	StructType Объект или отформатированная в формате DDL строка (например, 'col0 INT, col1 DOUBLE').

Возвраты

DataFrameReader

Примеры

Укажите схему при чтении CSV-файла.

import tempfile
with tempfile.TemporaryDirectory(prefix="schema") as d:
    spark.read.schema("col0 INT, col1 DOUBLE").format("csv").load(d).printSchema()
    # root
    #  |-- col0: integer (nullable = true)
    #  |-- col1: double (nullable = true)