typo

nemccarthy · Apr 7, 2015 · 2a1857a · 2a1857a
1 parent d2f053b
commit 2a1857a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/pyspark/shuffle.py b/python/pyspark/shuffle.py
@@ -651,7 +651,7 @@ def next(self):
 
 class ChainedIterable(object):
     """
-    Picklable chained iterator, similar to itertools.chain.fromiterable()
+    Picklable chained iterator, similar to itertools.chain.from_iterable()
     """
     def __init__(self, iterators):
         self.iterators = iterators
@@ -660,7 +660,7 @@ def __len__(self):
         return sum(len(vs) for vs in self.iterators)
 
     def __iter__(self):
-        return itertools.chain.fromiterable(self.iterators)
+        return itertools.chain.from_iterable(self.iterators)
 
 
 class ExternalGroupBy(ExternalMerger):