Oalex #13
|
@ -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") \
|
||||
|
|
Loading…
Reference in New Issue