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

5 votes216 views2 answers
Selenium get current url
Python
0 vote228 views1 answer
Python get all ips in a range
Python
0 vote226 views1 answer
Plt clor image histogram
Python
12 votes216 views3 answers
Setwd python
Python
41 votes214 views3 answers
Python - sort dictionary by value
Python
0 vote218 views3 answers
Hash function in Python
Python
0 vote223 views1 answer
Add a string to each element of a list python
Python
1 vote208 views1 answer
Count how many times a value shows in python list
Python
0 vote222 views2 answers
Read_json
Python
0 vote226 views1 answer
Sns.distplot fit
Python