input_file_name

Crée une colonne de chaîne pour le nom de fichier de la tâche Spark actuelle.

Syntaxe

from pyspark.sql import functions as sf

sf.input_file_name()

Retours

pyspark.sql.Column: noms de fichiers.

Examples

Exemple 1 : Obtenir le nom du fichier d’entrée

import os
from pyspark.sql import functions as sf
path = os.path.abspath(__file__)
df = spark.read.text(path)
df.select(sf.input_file_name()).first()

Row(input_file_name()='file:/...')