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 vote287 views1 answer
Python plot draw the goal line
Python
0 vote301 views1 answer
Shuffle text lines python
Python
3 votes321 views3 answers
2d array python initialize
Python
0 vote300 views1 answer
List Comprehension iteration
Python
0 vote223 views0 answer
Python
1 vote285 views1 answer
Change plot size matplotlib
Python
0 vote283 views1 answer
Install older version of python
Python
1 vote234 views1 answer
Python add word to list
Python
12 votes275 views2 answers
Python pip version check
Python
0 vote275 views2 answers
Pytest using tempfile
Python