şema

Giriş şemasını belirtir. Bazı veri kaynakları (JSON gibi) verilerden giriş şemasını otomatik olarak çıkarsayabilir. Şemayı burada belirterek, temel alınan veri kaynağı şema çıkarımı adımını atlayarak veri yükleme işlemini hızlandırabilir.

Sözdizimi

schema(schema)

Parametreler

Parametre	Türü	Açıklama
schema	StructType veya str	Bir StructType nesne veya DDL biçimli bir dize (örneğin, 'col0 INT, col1 DOUBLE').

İadeler

DataFrameReader

Örnekler

CSV dosyasını okurken şemayı belirtin.

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)