diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py index b612166835e14..7c1fbadcb82be 100644 --- a/python/pyspark/serializers.py +++ b/python/pyspark/serializers.py @@ -242,7 +242,7 @@ def cast_series(s, t): def loads(self, obj): """ - Deserialize an ArrowRecordBatch to an Arrow table and return as a list of pandas.Series + Deserialize an ArrowRecordBatch to an Arrow table and return as a list of pandas.Series. """ table = super(ArrowPandasSerializer, self).loads(obj) return [c.to_pandas() for c in table.itercolumns()]