schéma

Určuje vstupní schéma. Některé zdroje dat (například JSON) můžou automaticky odvodit vstupní schéma z dat. Zadáním schématu zde může podkladový zdroj dat přeskočit krok odvozování schématu, který urychluje načítání dat.

Syntaxe

schema(schema)

Parametry

Parameter	Typ	Description
schema	StructType nebo str	StructType Objekt nebo řetězec formátovaný DDL (například'col0 INT, col1 DOUBLE').

Návraty

DataFrameReader

Příklady

Zadejte schéma při čtení souboru 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)