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 vote185 views1 answer
Remove single and double quotes from string python
Python
0 vote183 views1 answer
Python tkinter treeview get selected item
Python
0 vote193 views1 answer
Docker python heelo world doesnt print anything
Python
0 vote172 views1 answer
Download python 3.8
Python
1 vote174 views1 answer
How to create an array with known length in python
Python
0 vote219 views1 answer
Django time cualtulate
Python Django
3 votes184 views2 answers
Date object into date format python
Python
1 vote174 views2 answers
Open choose files from file explorer python
Python
4 votes177 views4 answers
Jupyter lab autocomplete
Python
2 votes199 views1 answer
Tkinter input popup
Python