輸入檔案

回傳組成此資料框架檔案的盡力而為快照。 此方法只需向每個組成元件 BaseRelation 索取其相應檔案，並取得所有結果的聯集。 根據來源關係不同，這可能無法找到所有輸入檔案。 重複的會被刪除。

語法

inputFiles()

退貨

列表：檔案路徑列表。

Examples

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