CommencezCommencez gratuitement

UDF pandas

Cet exercice porte sur les UDF pandas, pour vous permettre de pratiquer leur syntaxe! En le réalisant, observez les différences entre la UDF PySpark de l'exercice précédent et ce type de UDF.

Rappelez-vous qu'une SparkSession appelée spark est déjà disponible dans votre espace de travail!

Cette activité fait partie du cours

Introduction à PySpark

Voir le cours

Instructions de l’exercice

  • Définissez la fonction add_ten_pandas() comme une UDF pandas.
  • Ajoutez une nouvelle colonne au DataFrame appelée "10_plus" qui applique la UDF pandas à la colonne "value" de df.
  • Affichez le DataFrame résultant.

Exercice interactif pratique

Essayez cet exercice en complétant ce code d’exemple.

# Define a Pandas UDF that adds 10 to each element in a vectorized way
@____(DoubleType())
def add_ten_pandas(column):
    return column + 10

# Apply the UDF and show the result
df.withColumn("10_plus", ____)
df.____
Modifier et exécuter le code