Pyspark: Suppose you want to do

df.groupBy('A').sum('B')

If it fails, then try

df.withColumnRenamed('A', 'A').groupBy('A').sum('B')

Rewrite the PageRank example using DataFrame AP. Here is a skeleton of the code. Your job is to fill in the missing part. The data files can be downloaded at: https://www.cse.ust.hk/msbd5003/data/pageran? data.txt https://www.cse.ust.hk/msbd5003/data/dblp.in from pyspark.sql.functions import* num0f!terations = 10 lines spark.read.text("pagerank_data.txt" # You can also test your program on the follow larger data set: a =lines. select(split(lines[0],' ')) links a.select(a[0] [0].alias('src, a[0]01].aliasC'dst) outdegrees -links.groupByC'src).countO ranks outdegrees.select('src', lit(1).aliasC'rank for iteration in range(numOfIterations): # FILL IN THIS PART ranks.orderBy(descC rank").showO Rewrite the PageRank example using DataFrame AP. Here is a skeleton of the code. Your job is to fill in the missing part. The data files can be downloaded at: https://www.cse.ust.hk/msbd5003/data/pageran? data.txt https://www.cse.ust.hk/msbd5003/data/dblp.in from pyspark.sql.functions import* num0f!terations = 10 lines spark.read.text("pagerank_data.txt" # You can also test your program on the follow larger data set: a =lines. select(split(lines[0],' ')) links a.select(a[0] [0].alias('src, a[0]01].aliasC'dst) outdegrees -links.groupByC'src).countO ranks outdegrees.select('src', lit(1).aliasC'rank for iteration in range(numOfIterations): # FILL IN THIS PART ranks.orderBy(descC rank").showO