schemat

Określa schemat wejściowy. Niektóre źródła danych (takie jak JSON) mogą automatycznie wnioskować schemat wejściowy z danych. Określając tutaj schemat, bazowe źródło danych może pominąć krok wnioskowania schematu, który przyspiesza ładowanie danych.

Składnia

schema(schema)

Parametry

Parameter	Typ	Opis
schema	Typ struktury lub str	StructType Obiekt lub ciąg w formacie DDL (na przykład 'col0 INT, col1 DOUBLE').

Zwroty

DataFrameReader

Examples

Określ schemat podczas odczytywania pliku 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)