Skip to content

Commit 9127d2b

Browse files
committed
[SPARK-2470] wrap expression lists in parentheses
1 parent 22132a4 commit 9127d2b

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

python/pyspark/serializers.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -196,8 +196,8 @@ def _load_stream_without_unbatching(self, stream):
196196
return self.serializer.load_stream(stream)
197197

198198
def __eq__(self, other):
199-
return isinstance(other, BatchedSerializer) and
200-
other.serializer == self.serializer
199+
return (isinstance(other, BatchedSerializer) and
200+
other.serializer == self.serializer)
201201

202202
def __str__(self):
203203
return "BatchedSerializer<%s>" % str(self.serializer)
@@ -228,8 +228,8 @@ def load_stream(self, stream):
228228
yield pair
229229

230230
def __eq__(self, other):
231-
return isinstance(other, CartesianDeserializer) and
232-
self.key_ser == other.key_ser and self.val_ser == other.val_ser
231+
return (isinstance(other, CartesianDeserializer) and
232+
self.key_ser == other.key_ser and self.val_ser == other.val_ser)
233233

234234
def __str__(self):
235235
return "CartesianDeserializer<%s, %s>" % \
@@ -251,8 +251,8 @@ def load_stream(self, stream):
251251
yield pair
252252

253253
def __eq__(self, other):
254-
return isinstance(other, PairDeserializer) and
255-
self.key_ser == other.key_ser and self.val_ser == other.val_ser
254+
return (isinstance(other, PairDeserializer) and
255+
self.key_ser == other.key_ser and self.val_ser == other.val_ser)
256256

257257
def __str__(self):
258258
return "PairDeserializer<%s, %s>" % (str(self.key_ser), str(self.val_ser))

0 commit comments

Comments
 (0)