Poznámka:
Přístup k této stránce vyžaduje autorizaci. Můžete se zkusit přihlásit nebo změnit adresáře.
Přístup k této stránce vyžaduje autorizaci. Můžete zkusit změnit adresáře.
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|
# +---+----+