We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7e02ea3 commit 84dd277Copy full SHA for 84dd277
python/pyspark/sql/cogroup.py
@@ -85,7 +85,7 @@ def apply(self, udf):
85
the grouping key(s) will be passed as the first argument and the data will be passed as the
86
second and third arguments. The grouping key(s) will be passed as a tuple of numpy data
87
types, e.g., `numpy.int32` and `numpy.float64`. The data will still be passed in as two
88
- `pandas.DataFrame`s containing all columns from the original Spark DataFrames.
+ `pandas.DataFrame` containing all columns from the original Spark DataFrames.
89
90
>>> @pandas_udf("time int, id int, v1 double, v2 string",
91
... PandasUDFType.COGROUPED_MAP) # doctest: +SKIP
0 commit comments