diff options
| author | Davies Liu <davies.liu@gmail.com> | 2014-08-06 11:08:12 -0700 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2014-08-06 11:08:23 -0700 |
| commit | 27a8d4ce39aa620a5926b33371fcf03bbcb18698 (patch) | |
| tree | 387fbb2c70cd2abe993e6009157dd76d6afd0f60 /python | |
| parent | 31090e43ca91f687b0bc6e25c824dc25bd7027cd (diff) | |
| download | spark-27a8d4ce39aa620a5926b33371fcf03bbcb18698.tar.gz spark-27a8d4ce39aa620a5926b33371fcf03bbcb18698.tar.bz2 spark-27a8d4ce39aa620a5926b33371fcf03bbcb18698.zip | |
[SPARK-2875] [PySpark] [SQL] handle null in schemaRDD()
Handle null in schemaRDD during converting them into Python.
Author: Davies Liu <davies.liu@gmail.com>
Closes #1802 from davies/json and squashes the following commits:
88e6b1f [Davies Liu] handle null in schemaRDD()
(cherry picked from commit 48789117c2dd6d38e0bd8d21cdbcb989913205a6)
Signed-off-by: Michael Armbrust <michael@databricks.com>
Diffstat (limited to 'python')
| -rw-r--r-- | python/pyspark/sql.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/python/pyspark/sql.py b/python/pyspark/sql.py index f1093701dd..adc56e7ec0 100644 --- a/python/pyspark/sql.py +++ b/python/pyspark/sql.py @@ -1231,6 +1231,13 @@ class SQLContext: ... "field3.field5[0] as f3 from table3") >>> srdd6.collect() [Row(f1=u'row1', f2=None,...Row(f1=u'row3', f2=[], f3=None)] + + >>> sqlCtx.jsonRDD(sc.parallelize(['{}', + ... '{"key0": {"key1": "value1"}}'])).collect() + [Row(key0=None), Row(key0=Row(key1=u'value1'))] + >>> sqlCtx.jsonRDD(sc.parallelize(['{"key0": null}', + ... '{"key0": {"key1": "value1"}}'])).collect() + [Row(key0=None), Row(key0=Row(key1=u'value1'))] """ def func(iterator): |