From 982a1b0b9f9ba06256eaff9722cdbff77aa96e41 Mon Sep 17 00:00:00 2001 From: Miriam Baglioni Date: Thu, 5 Dec 2024 12:21:21 +0100 Subject: [PATCH] [oalex] change the call of the function in the dataframe --- strings.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/strings.py b/strings.py index fd67cd6..8c00b65 100644 --- a/strings.py +++ b/strings.py @@ -47,7 +47,7 @@ explode = spark.read.json(folder_path) \ affs = explode \ .select("affiliation") \ .distinct() \ - .withColumn("Matchings", oalex_affro(col("aff_string"))) + .withColumn("Matchings", oalex_affro_udf(col("aff_string"))) affs.join(explode, on = "affiliation") \