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 vote213 views1 answer
How to convert linked list to list in python
Python
0 vote174 views1 answer
Tf.io path copy
Python
5 votes226 views2 answers
Allauth django
Python Django
3 votes165 views2 answers
Moving element to last position in a list python
Python
6 votes228 views1 answer
How to create migrations in django
Python Django
0 vote186 views1 answer
Create and activate virtual environment with python 3
Python
0 vote170 views1 answer
Python max of two numbers
Python
0 vote183 views1 answer
Default dictionary value
Python
0 vote214 views4 answers
Unpacking of tuples in python
Python
0 vote172 views1 answer
Splitting column values in pandas
Python