Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 4 additions & 2 deletions python/pyspark/sql/pandas/map_ops.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,8 @@ def mapInPandas(
together as an iterator of `pandas.DataFrame`\\s to the function and the
returned iterator of `pandas.DataFrame`\\s are combined as a :class:`DataFrame`.
Each `pandas.DataFrame` size can be controlled by
`spark.sql.execution.arrow.maxRecordsPerBatch`.
`spark.sql.execution.arrow.maxRecordsPerBatch`. The size of the function's input and
output can be different.

.. versionadded:: 3.0.0

Expand Down Expand Up @@ -108,7 +109,8 @@ def mapInArrow(
together as an iterator of `pyarrow.RecordBatch`\\s to the function and the
returned iterator of `pyarrow.RecordBatch`\\s are combined as a :class:`DataFrame`.
Each `pyarrow.RecordBatch` size can be controlled by
`spark.sql.execution.arrow.maxRecordsPerBatch`.
`spark.sql.execution.arrow.maxRecordsPerBatch`. The size of the function's input and
output can be different.

.. versionadded:: 3.3.0

Expand Down