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") \