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

0 vote126 views1 answer
Rename a variable using .format in python
Python
2 votes130 views1 answer
How to get the last value in a list python
Python
0 vote107 views1 answer
How to convert a axis label to non scientific notation in matploltlib
Python
0 vote114 views1 answer
Django pass list of fields to values
Python
0 vote125 views1 answer
Df.loc jupyter
Python
0 vote99 views1 answer
How to create frequency table in python
Python
0 vote111 views2 answers
How do i make a for loop in python
Python
0 vote161 views1 answer
Mad libs game prompt python
Python
17 votes112 views6 answers
Remove list from list python
Python
0 vote136 views1 answer
Django versatileimagefield
Python Django