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

16 votes189 views3 answers
Python gitignore
Python
4 votes241 views6 answers
Hex to rgb python
Python
0 vote243 views1 answer
What is horse riding sport name
Python
1 vote223 views3 answers
Urllib urlretrieve python 3
Python
0 vote261 views1 answer
Test if instance in queryset django
Python Django
1 vote229 views1 answer
Python how to add turtle in tkinter
Python
31 votes169 views1 answer
Control tor browser with python
Python
0 vote191 views1 answer
How to redirect in django rest framework
Python
1 vote179 views1 answer
Install python3.6 in linux
Python
2 votes217 views1 answer
Pygame get screen width and height
Python