diff options
| author | Josh Rosen <joshrosen@apache.org> | 2013-11-26 14:35:12 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@apache.org> | 2013-11-26 14:35:12 -0800 |
| commit | 1b74a27da026aba7dbe2088ee64974d772feb23d (patch) | |
| tree | 8361b1a39cd2c7a787e7b9817eb1c723ec078aec /python/pyspark/serializers.py | |
| parent | 13122ceb8c74dc0c4ad37902a3d1b30bf273cc6a (diff) | |
| download | spark-1b74a27da026aba7dbe2088ee64974d772feb23d.tar.gz spark-1b74a27da026aba7dbe2088ee64974d772feb23d.tar.bz2 spark-1b74a27da026aba7dbe2088ee64974d772feb23d.zip | |
Removed unused basestring case from dump_stream.
Diffstat (limited to 'python/pyspark/serializers.py')
| -rw-r--r-- | python/pyspark/serializers.py | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py index 9338df69ff..811fa6f018 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): |