HyukjinKwon opened a new pull request, #41250:
URL: https://github.com/apache/spark/pull/41250

   ### What changes were proposed in this pull request?
   
   This PR implements `SparkSession.addArtifact(s)`. The logic is basically 
translated from Scala (https://github.com/apache/spark/pull/40256) to Python 
here.
   
   One difference is that, it does not support `class` files and `cache` 
(https://github.com/apache/spark/pull/40827) because it's not realistic for 
Python client to add `class` files. For `cache`, this implementation will be 
used as a base work.
   
   This PR is also a base work to implement sending py-files and archive files
   
   ### Why are the changes needed?
   
   For feature parity w/ Scala client. In addition, this is also base work for 
`cache` implementation, and Python dependency management 
(https://www.databricks.com/blog/2020/12/22/how-to-manage-python-dependencies-in-pyspark.html)
   
   ### Does this PR introduce _any_ user-facing change?
   
   Yes, this exposes an API `SparkSession.addArtifact(s)`.
   
   ### How was this patch tested?
   
   Unittests were added. Also manually tested.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to