aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/accumulators.py
diff options
context:
space:
mode:
authorDavies Liu <davies@databricks.com>2014-11-24 16:41:23 -0800
committerPatrick Wendell <pwendell@gmail.com>2014-11-24 16:41:32 -0800
commit8371bc20821c39ee6d8116a867577e5c0fcd08ab (patch)
tree9e3a7f05cc1a8ceef18a49b9da07a5456fdf752b /python/pyspark/accumulators.py
parent2acbd2884f73c4503d753bb96e0acf75cd237536 (diff)
downloadspark-8371bc20821c39ee6d8116a867577e5c0fcd08ab.tar.gz
spark-8371bc20821c39ee6d8116a867577e5c0fcd08ab.tar.bz2
spark-8371bc20821c39ee6d8116a867577e5c0fcd08ab.zip
[SPARK-4578] fix asDict() with nested Row()
The Row object is created on the fly once the field is accessed, so we should access them by getattr() in asDict(0 Author: Davies Liu <davies@databricks.com> Closes #3434 from davies/fix_asDict and squashes the following commits: b20f1e7 [Davies Liu] fix asDict() with nested Row() (cherry picked from commit 050616b408c60eae02256913ceb645912dbff62e) Signed-off-by: Patrick Wendell <pwendell@gmail.com>
Diffstat (limited to 'python/pyspark/accumulators.py')
0 files changed, 0 insertions, 0 deletions