Skip to content

Commit

Permalink
[SPARK-2470] wrap expression lists in parentheses
Browse files Browse the repository at this point in the history
  • Loading branch information
nchammas committed Jul 21, 2014
1 parent 22132a4 commit 9127d2b
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions python/pyspark/serializers.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down Expand Up @@ -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>" % \
Expand All @@ -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))
Expand Down

0 comments on commit 9127d2b

Please sign in to comment.