csv (DataFrameReader)

Načte soubor CSV a vrátí výsledek jako DataFrame. Pokud inferSchema je tato funkce povolená, přečte vstup jednou za účelem určení schématu. Chcete-li tomu zabránit, zakažte inferSchema nebo zadejte schéma explicitně pomocí schema.

Syntaxe

csv(path, schema=None, **options)

Parametry

Parameter	Typ	Description
path	str nebo list	Jedna nebo více vstupních cest nebo sada RDD řetězců, které ukládají řádky CSV.
schema	StructType nebo str, volitelné	Volitelné vstupní schéma jako StructType objekt nebo řetězec formátovaný DDL (například 'col0 INT, col1 DOUBLE').

Návraty

DataFrame

Příklady

Zapište datový rámec do souboru CSV a přečtěte si ho zpátky.

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

    spark.read.csv(d, schema=df.schema, nullValue="Alice").show()
    # +---+----+
    # |age|name|
    # +---+----+
    # |100|NULL|
    # +---+----+