aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/serializers.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/pyspark/serializers.py')
-rw-r--r--python/pyspark/serializers.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py
index 2672da36c1..099fa54cf2 100644
--- a/python/pyspark/serializers.py
+++ b/python/pyspark/serializers.py
@@ -211,7 +211,7 @@ class BatchedSerializer(Serializer):
return (isinstance(other, BatchedSerializer) and
other.serializer == self.serializer)
- def __str__(self):
+ def __repr__(self):
return "BatchedSerializer<%s>" % str(self.serializer)
@@ -279,7 +279,7 @@ class CartesianDeserializer(FramedSerializer):
return (isinstance(other, CartesianDeserializer) and
self.key_ser == other.key_ser and self.val_ser == other.val_ser)
- def __str__(self):
+ def __repr__(self):
return "CartesianDeserializer<%s, %s>" % \
(str(self.key_ser), str(self.val_ser))
@@ -306,7 +306,7 @@ class PairDeserializer(CartesianDeserializer):
return (isinstance(other, PairDeserializer) and
self.key_ser == other.key_ser and self.val_ser == other.val_ser)
- def __str__(self):
+ def __repr__(self):
return "PairDeserializer<%s, %s>" % (str(self.key_ser), str(self.val_ser))