You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2013/11/27 05:56:03 UTC
[6/7] git commit: Removed unused basestring case from dump_stream.
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 <jo...@apache.org>
Authored: Tue Nov 26 14:35:12 2013 -0800
Committer: Josh Rosen <jo...@apache.org>
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):