pyspark.sql.DataFrame.inputFiles

DataFrame。 inputFiles ( )→列表(str]

返回一個最優的快照文件組成DataFrame。這種方法隻要求每個組成BaseRelation各自的文件,需要工會的所有結果。根據源關係,這可能沒有找到所有輸入文件。重複刪除。

例子

> > >df=火花負載(“例子/ src / main /資源/ people.json”,格式=“json”)> > >如果操作係統環境得到(“PYTEST_DBCONNECT_MODE”)沒有一個:len(dfinputFiles())其他的:1# dbconnect不支持inputFiles因此黑客跳過檢查這裏1