Skip to content

Commit e343f68

Browse files
committed
code review update: replace series#values to series#array
1 parent 10d4bcf commit e343f68

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

python/pyspark/sql/pandas/serializers.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,7 @@ def _create_batch(self, series):
215215
series = ((s, None) if not isinstance(s, (list, tuple)) else s for s in series)
216216

217217
def create_array(s, t):
218-
if hasattr(s.values, "__arrow_array__"):
218+
if hasattr(s.array, "__arrow_array__"):
219219
mask = None
220220
else:
221221
mask = s.isnull()

0 commit comments

Comments
 (0)