skema

Menentukan skema input. Beberapa sumber data (seperti JSON) dapat menyimpulkan skema input secara otomatis dari data. Dengan menentukan skema di sini, sumber data yang mendasarinya dapat melewati langkah inferensi skema, yang mempercepat pemuatan data.

Sintaksis

schema(schema)

Parameter-parameternya

Parameter	Tipe	Deskripsi
schema	StructType atau str	Objek StructType atau string berformat DDL (misalnya, 'col0 INT, col1 DOUBLE').

Pengembalian Barang

DataFrameReader

Examples

Tentukan skema saat membaca file 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)