Skip to content

Commit 6bd03d1

Browse files
committed
Revert "use substring in __getitem__ to avoid column name change"
This reverts commit d611fd5.
1 parent b5ec266 commit 6bd03d1

2 files changed

Lines changed: 7 additions & 7 deletions

File tree

python/pyspark/sql/column.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -712,19 +712,19 @@ def __getitem__(self, k: Any) -> "Column":
712712
--------
713713
>>> df = spark.createDataFrame([('abcedfg', {"key": "value"})], ["l", "d"])
714714
>>> df.select(df.l[slice(1, 3)], df.d['key']).show()
715-
+------------------+------+
716-
|substring(l, 1, 3)|d[key]|
717-
+------------------+------+
718-
| abc| value|
719-
+------------------+------+
715+
+---------------+------+
716+
|substr(l, 1, 3)|d[key]|
717+
+---------------+------+
718+
| abc| value|
719+
+---------------+------+
720720
"""
721721
if isinstance(k, slice):
722722
if k.step is not None:
723723
raise PySparkValueError(
724724
error_class="SLICE_WITH_STEP",
725725
message_parameters={},
726726
)
727-
return self.substring(k.start, k.stop)
727+
return self.substr(k.start, k.stop)
728728
else:
729729
return _bin_op("apply")(self, k)
730730

python/pyspark/sql/connect/column.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -460,7 +460,7 @@ def __getitem__(self, k: Any) -> "Column":
460460
error_class="SLICE_WITH_STEP",
461461
message_parameters={},
462462
)
463-
return self.substring(k.start, k.stop)
463+
return self.substr(k.start, k.stop)
464464
else:
465465
return Column(UnresolvedExtractValue(self._expr, LiteralExpression._from_value(k)))
466466

0 commit comments

Comments
 (0)