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

2 votes177 views1 answer
Django EMAIL_BACKEND console
Python
0 vote179 views1 answer
Python largest common divisor
Python
-3 votes204 views2 answers
How to move turtle forward in python
Python
0 vote193 views1 answer
Unity python
Python
6 votes195 views3 answers
Example images
Python
15 votes188 views5 answers
How to convert dataframe to list in python
Python
0 vote189 views10 answers
Loop
Python
0 vote228 views1 answer
Default orange and blue matplotlib
Python
146 votes182 views6 answers
Install pip python
Python
5 votes170 views2 answers
Pip pandas
Python