pyspark.sql.PandasCogroupedOps

class pyspark.sql.PandasCogroupedOps(gd1: GroupedData, gd2: GroupedData)

A logical grouping of two GroupedData, created by GroupedData.cogroup().

Notes

This API is experimental.

Methods

applyInPandas(func, schema)

Applies a function to each cogroup using pandas and returns the result as a DataFrame.