pyspark.sql.functions.input_file_name

pyspark.sql.functions.input_file_name() → pyspark.sql.column.Column[source]

Creates a string column for the file name of the current Spark task.

New in version 1.6.