načíst

Načte data ze zdroje dat a vrátí je jako DataFrame.

Syntaxe

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

Parametry

Parameter Typ Description
path str nebo list, volitelné Jedna nebo více cest ve zdroji dat založeném na systému souborů.
format str, volitelné Formát zdroje dat. Výchozí hodnota je 'parquet'.
schema StructType nebo str, volitelné Vstupní schéma jako StructType objekt nebo řetězec formátovaný DDL (například 'col0 INT, col1 DOUBLE').
**options slovník Další možnosti řetězce

Návraty

DataFrame

Příklady

Načtěte soubor CSV se zadaným formátem, schématem a možnostmi.

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