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/tests.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/tests.py')
| -rw-r--r-- | python/pyspark/tests.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/python/pyspark/tests.py b/python/pyspark/tests.py index 8bfed074c9..647504c32f 100644 --- a/python/pyspark/tests.py +++ b/python/pyspark/tests.py @@ -218,6 +218,11 @@ class SerializationTestCase(unittest.TestCase): p2 = loads(dumps(p1, 2)) self.assertEqual(p1, p2) + from pyspark.cloudpickle import dumps + P2 = loads(dumps(P)) + p3 = P2(1, 3) + self.assertEqual(p1, p3) + def test_itemgetter(self): from operator import itemgetter ser = CloudPickleSerializer() |