From 2a1857a4c1d72bee5a93ffbe1da013ffc7ff673b Mon Sep 17 00:00:00 2001 From: Davies Liu Date: Tue, 7 Apr 2015 10:46:32 -0700 Subject: [PATCH] typo --- python/pyspark/shuffle.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python/pyspark/shuffle.py b/python/pyspark/shuffle.py index 1393ac9df9bd7..62d76f96b91b8 100644 --- 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):