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 vote220 views1 answer
Pytest loop
Python
1 vote240 views1 answer
Python <>
Python
0 vote299 views1 answer
Python json random number generator
Python
0 vote251 views1 answer
How to hash out a big paragraph in vs code python
Python
0 vote256 views1 answer
Location of matploitlibrc file
Python
0 vote236 views2 answers
Python sorting array without inbuilt sort
Python
66 votes239 views6 answers
Make directory python
Python
0 vote247 views1 answer
Get current module name python
Python
0 vote229 views1 answer
To text pandas
Python
0 vote238 views1 answer
Define a function in python without arguments
Python