Skip to content

RelationalGroupedDataset

RelationalGroupedDataset is a result of executing high-level grouping operators.

This is a stub

This page is a stub to describe PySpark-related methods only. Learn more about RelationalGroupedDataset in The Internals of Spark SQL.

flatMapCoGroupsInPandas

flatMapCoGroupsInPandas(
  r: RelationalGroupedDataset,
  expr: PythonUDF): DataFrame

flatMapCoGroupsInPandas...FIXME

flatMapCoGroupsInPandas is used when:

flatMapGroupsInPandas

flatMapGroupsInPandas(
  expr: PythonUDF): DataFrame

flatMapGroupsInPandas creates a DataFrame with a FlatMapGroupsInPandas logical operator (to execute the given PythonUDF).

flatMapGroupsInPandas asserts that the input PythonUDF is a grouped map udf (the eval type is SQL_GROUPED_MAP_PANDAS_UDF).

flatMapGroupsInPandas asserts that the return type of the input PythonUDF is StructType.

flatMapGroupsInPandas is used when: