diff options
| author | Davies Liu <davies@databricks.com> | 2015-09-14 19:46:34 -0700 |
|---|---|---|
| committer | Davies Liu <davies.liu@gmail.com> | 2015-09-14 19:46:34 -0700 |
| commit | 55204181004c105c7a3e8c31a099b37e48bfd953 (patch) | |
| tree | 7a052c7f9c6fb4bb96e2db7c213c49257141e865 /python/pyspark/serializers.py | |
| parent | 1a0955250bb65cd6f5818ad60efb62ea4b45d18e (diff) | |
| download | spark-55204181004c105c7a3e8c31a099b37e48bfd953.tar.gz spark-55204181004c105c7a3e8c31a099b37e48bfd953.tar.bz2 spark-55204181004c105c7a3e8c31a099b37e48bfd953.zip | |
[SPARK-10542] [PYSPARK] fix serialize namedtuple
Author: Davies Liu <davies@databricks.com>
Closes #8707 from davies/fix_namedtuple.
Diffstat (limited to 'python/pyspark/serializers.py')
| -rw-r--r-- | python/pyspark/serializers.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/python/pyspark/serializers.py b/python/pyspark/serializers.py index 411b4dbf48..2a1326947f 100644 --- a/python/pyspark/serializers.py +++ b/python/pyspark/serializers.py @@ -359,6 +359,7 @@ def _hack_namedtuple(cls): def __reduce__(self): return (_restore, (name, fields, tuple(self))) cls.__reduce__ = __reduce__ + cls._is_namedtuple_ = True return cls |