Removed unused basestring case from dump_stream.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/1b74a27d Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/1b74a27d Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/1b74a27d Branch: refs/heads/master Commit: 1b74a27da026aba7dbe2088ee64974d772feb23d Parents: 13122ce Author: Josh Rosen <[email protected]> Authored: Tue Nov 26 14:35:12 2013 -0800 Committer: Josh Rosen <[email protected]> Committed: Tue Nov 26 14:35:12 2013 -0800 ---------------------------------------------------------------------- python/pyspark/serializers.py | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/1b74a27d/python/pyspark/serializers.py ---------------------------------------------------------------------- diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py index 9338df6..811fa6f 100644 --- a/python/pyspark/serializers.py +++ b/python/pyspark/serializers.py @@ -179,8 +179,6 @@ class BatchedSerializer(Serializer): yield items def dump_stream(self, iterator, stream): - if isinstance(iterator, basestring): - iterator = [iterator] self.serializer.dump_stream(self._batched(iterator), stream) def load_stream(self, stream):
