memuat

Memuat data dari sumber data dan mengembalikannya sebagai DataFrame.

Sintaksis

load(path=None, format=None, schema=None, **options)

Parameter-parameternya

Parameter	Tipe	Deskripsi
path	str atau daftar, opsional	Satu atau beberapa jalur di sumber data yang didukung sistem file.
format	str, opsional	Format sumber data. Secara default menjadi 'parquet'.
schema	StructType atau str, opsional	Skema input sebagai StructType objek atau string berformat DDL (misalnya, 'col0 INT, col1 DOUBLE').
**options	kamus	Opsi string tambahan.

Pengembalian Barang

DataFrame

Examples

Muat file CSV dengan format, skema, dan opsi yang ditentukan.

import tempfile
with tempfile.TemporaryDirectory(prefix="load") as d:
    df = spark.createDataFrame([{"age": 100, "name": "Alice"}])
    df.write.option("header", True).mode("overwrite").format("csv").save(d)

    df = spark.read.load(
        d, schema=df.schema, format="csv", nullValue="Alice", header=True)
    df.printSchema()
    # root
    #  |-- age: long (nullable = true)
    #  |-- name: string (nullable = true)
    df.show()
    # +---+----+
    # |age|name|
    # +---+----+
    # |100|NULL|
    # +---+----+