inputFiles

Bu DataFrame'i oluşturan dosyaların en iyi çaba anlık görüntüsünü döndürür. Bu yöntem yalnızca ilgili dosyaları için her bir kurucu BaseRelation sorar ve tüm sonuçların birleşimini alır. Kaynak ilişkilerine bağlı olarak, bu tüm giriş dosyalarını bulamayabilir. Yinelenenler kaldırılır.

Sözdizimi

inputFiles()

İadeler

list: Dosya yollarının listesi.

Örnekler

import os
import tempfile
with tempfile.TemporaryDirectory(prefix="inputFiles") as d:
    spark.createDataFrame(
        [{"age": 100, "name": "Alice"}]
    ).repartition(1).write.json(d, mode="overwrite")

    df = spark.read.format("json").load(d)

    if os.environ.get('PYTEST_DBCONNECT_MODE') is None:
        len(df.inputFiles())
    else:
        1  # dbconnect doesn't support inputFiles.
# 1