correct the lines wrapping

holdenk · Mar 7, 2014 · 1fea813 · 1fea813
1 parent d0c71f3
commit 1fea813
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
@@ -331,9 +331,10 @@ def intersection(self, other):
         >>> rdd1.intersection(rdd2).collect()
         [1, 2, 3]
         """
-        return self.map(lambda v: (v, None)).cogroup(
-            other.map(lambda v: (v, None))).filter(
-            lambda x: (len(x[1][0]) != 0) and (len(x[1][1]) != 0)).keys()
+        return self.map(lambda v: (v, None)) \
+            .cogroup(other.map(lambda v: (v, None))) \
+            .filter(lambda x: (len(x[1][0]) != 0) and (len(x[1][1]) != 0)) \
+            .keys()
 
     def _reserialize(self):
         if self._jrdd_deserializer == self.ctx.serializer: