Yük

Bir veri kaynağından verileri yükler ve olarak DataFramedöndürür.

Sözdizimi

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

Parametreler

Parametre	Türü	Açıklama
path	str veya list, isteğe bağlı	Dosya sistemi destekli veri kaynağında bir veya daha fazla yol.
format	str, isteğe bağlı	Veri kaynağının biçimi. Varsayılan olarak 'parquet' değerini alır.
schema	StructType veya str, isteğe bağlı	Nesne olarak StructType giriş şeması veya DDL biçimli dize (örneğin, 'col0 INT, col1 DOUBLE').
**options	Dict	Ek dize seçenekleri.

İadeler

DataFrame

Örnekler

Biçim, şema ve seçenekler belirtilen bir CSV dosyası yükleyin.

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|
    # +---+----+