-
- Downloads
[SPARK-3886] [PySpark] simplify serializer, use AutoBatchedSerializer by default.
This PR simplify serializer, always use batched serializer (AutoBatchedSerializer as default), even batch size is 1. Author: Davies Liu <davies@databricks.com> This patch had conflicts when merged, resolved by Committer: Josh Rosen <joshrosen@databricks.com> Closes #2920 from davies/fix_autobatch and squashes the following commits: e544ef9 [Davies Liu] revert unrelated change 6880b14 [Davies Liu] Merge branch 'master' of github.com:apache/spark into fix_autobatch 1d557fc [Davies Liu] fix tests 8180907 [Davies Liu] Merge branch 'master' of github.com:apache/spark into fix_autobatch 76abdce [Davies Liu] clean up 53fa60b [Davies Liu] Merge branch 'master' of github.com:apache/spark into fix_autobatch d7ac751 [Davies Liu] Merge branch 'master' of github.com:apache/spark into fix_autobatch 2cc2497 [Davies Liu] Merge branch 'master' of github.com:apache/spark into fix_autobatch b4292ce [Davies Liu] fix bug in master d79744c [Davies Liu] recover hive tests be37ece [Davies Liu] refactor eb3938d [Davies Liu] refactor serializer in scala 8d77ef2 [Davies Liu] simplify serializer, use AutoBatchedSerializer by default.
Showing
- core/src/main/scala/org/apache/spark/api/python/PythonHadoopUtil.scala 2 additions, 4 deletions.../scala/org/apache/spark/api/python/PythonHadoopUtil.scala
- core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala 5 additions, 105 deletions...rc/main/scala/org/apache/spark/api/python/PythonRDD.scala
- core/src/main/scala/org/apache/spark/api/python/SerDeUtil.scala 90 additions, 31 deletions...rc/main/scala/org/apache/spark/api/python/SerDeUtil.scala
- core/src/main/scala/org/apache/spark/api/python/WriteInputFormatTestDataGenerator.scala 5 additions, 5 deletions.../spark/api/python/WriteInputFormatTestDataGenerator.scala
- mllib/src/main/scala/org/apache/spark/mllib/api/python/PythonMLLibAPI.scala 1 addition, 1 deletion...la/org/apache/spark/mllib/api/python/PythonMLLibAPI.scala
- python/pyspark/context.py 20 additions, 38 deletionspython/pyspark/context.py
- python/pyspark/mllib/common.py 1 addition, 1 deletionpython/pyspark/mllib/common.py
- python/pyspark/mllib/recommendation.py 1 addition, 1 deletionpython/pyspark/mllib/recommendation.py
- python/pyspark/rdd.py 37 additions, 54 deletionspython/pyspark/rdd.py
- python/pyspark/serializers.py 13 additions, 23 deletionspython/pyspark/serializers.py
- python/pyspark/shuffle.py 3 additions, 4 deletionspython/pyspark/shuffle.py
- python/pyspark/sql.py 7 additions, 11 deletionspython/pyspark/sql.py
- python/pyspark/tests.py 12 additions, 54 deletionspython/pyspark/tests.py
- sql/core/src/main/scala/org/apache/spark/sql/SchemaRDD.scala 4 additions, 6 deletionssql/core/src/main/scala/org/apache/spark/sql/SchemaRDD.scala
Loading
Please register or sign in to comment