[SPARK-2470] wrap expression lists in parentheses

ThalesGroup · Jul 21, 2014 · 9127d2b · 9127d2b
1 parent 22132a4
commit 9127d2b
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py
@@ -196,8 +196,8 @@ def _load_stream_without_unbatching(self, stream):
             return self.serializer.load_stream(stream)
 
     def __eq__(self, other):
-        return isinstance(other, BatchedSerializer) and
-        other.serializer == self.serializer
+        return (isinstance(other, BatchedSerializer) and
+                other.serializer == self.serializer)
 
     def __str__(self):
         return "BatchedSerializer<%s>" % str(self.serializer)
@@ -228,8 +228,8 @@ def load_stream(self, stream):
                 yield pair
 
     def __eq__(self, other):
-        return isinstance(other, CartesianDeserializer) and
-        self.key_ser == other.key_ser and self.val_ser == other.val_ser
+        return (isinstance(other, CartesianDeserializer) and
+                self.key_ser == other.key_ser and self.val_ser == other.val_ser)
 
     def __str__(self):
         return "CartesianDeserializer<%s, %s>" % \
@@ -251,8 +251,8 @@ def load_stream(self, stream):
                 yield pair
 
     def __eq__(self, other):
-        return isinstance(other, PairDeserializer) and
-        self.key_ser == other.key_ser and self.val_ser == other.val_ser
+        return (isinstance(other, PairDeserializer) and
+                self.key_ser == other.key_ser and self.val_ser == other.val_ser)
 
     def __str__(self):
         return "PairDeserializer<%s, %s>" % (str(self.key_ser), str(self.val_ser))