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 vote174 views1 answer
Python convert list of lists of strings to int
Python
0 vote140 views1 answer
Replace substrings in python
Python
2 votes130 views1 answer
Pytplot arc
Python
1 vote122 views2 answers
Git help
Python
0 vote140 views1 answer
Polycarp and Coins codeforces solution
Python
1 vote161 views1 answer
How to view the whole dataset in jupyternotebook
Python
7 votes123 views5 answers
Remove extension from filename python
Python
0 vote134 views1 answer
Os.system('clear')
Python
0 vote143 views1 answer
S = 1 + 2 + ... + n in python
Python
1 vote158 views1 answer
Split a given number in python
Python