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

48 votes171 views6 answers
Assembly
Python
0 vote148 views1 answer
How to run python code on github
Python
0 vote202 views1 answer
Django button
Python Django
1 vote163 views1 answer
Django loop index
Python Django
4 votes140 views1 answer
Replace empty string and "records with only spaces" with npnan pandas
Python
1 vote153 views1 answer
Export python pandas dataframe as json file
Python
2 votes198 views3 answers
Mongodb between two values
Python
-1 vote156 views1 answer
Py string find regex pos
Python
6 votes190 views5 answers
Django logout
Python Django
4 votes153 views1 answer
How to print an input backwards in python
Python