From 1b74a27da026aba7dbe2088ee64974d772feb23d Mon Sep 17 00:00:00 2001
From: Josh Rosen <joshrosen@apache.org>
Date: Tue, 26 Nov 2013 14:35:12 -0800
Subject: [PATCH] Removed unused basestring case from dump_stream.
---
python/pyspark/serializers.py | 2 --
1 file changed, 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):
--
GitLab