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

2 votes198 views3 answers
Python rotate list
Python
1 vote228 views1 answer
Python split list into n sublists
Python
0 vote206 views1 answer
What is kernel_initializer
Python
0 vote184 views2 answers
Numpy linspace
Python
80 votes238 views6 answers
Python code to exe file
Python
13 votes283 views6 answers
Django orm
Python Django
0 vote192 views2 answers
Converting list of arrays with same size to single array python
Python
0 vote191 views1 answer
Data must be 1-dimensional pd.dataframe
Python
19 votes266 views6 answers
Install Django in Windows
Python Django
0 vote222 views1 answer
Power of array
Python