Pyspark pivot max aggregation

from pyspark.sql.functions import *
from pyspark.sql import Window
var win = Window.partitionBy("date") 
data.withColumn("max_vol",max("volume").over(win)).groupBy("date","max_vol") .pivot("recipe") .agg(avg("percent")).show()

Source: stackoverflow.com

Similar codes

1 vote246 views1 answer
How to take input complex number in python
Python
0 vote257 views1 answer
List files in s3 folder python
Python
29 votes266 views1 answer
Df dropna ensure that one column is not nan
Python
0 vote284 views1 answer
Make a effective figure in python
Python
25 votes251 views5 answers
Python print timestamp
Python
3 votes283 views3 answers
How to append items to a list in python
Python
0 vote245 views1 answer
Python - Cómo comprobar si dos cuerdas son anagramas
Python
7 votes292 views5 answers
Django messages
Python Django
0 vote248 views1 answer
Devu and friendship testing codechef solution
Python
3 votes281 views2 answers
Django get parameters from url
Python Django