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 vote227 views1 answer
Import folder from another folder python
Python
0 vote259 views1 answer
Python password with special characters
Python
0 vote255 views1 answer
Python Django Models Unique Rows
Python Django
0 vote251 views1 answer
Python - Cómo Jugar archivo Mp3
Python
19 votes235 views1 answer
Python substring from end
Python
0 vote232 views1 answer
Finding the rows in a dataframe where column contains any of these values python
Python
0 vote226 views1 answer
Example 1: Reset Index & Drop Old Index pandas
Python
13 votes237 views1 answer
Check strings last letter python
Python
0 vote233 views2 answers
Sqlite to python list
Python
1 vote242 views1 answer
How to make a PKCS8 RSA signature in python
Python