First zip all of the dependencies into zip file like this. Then you can use one of the following methods to import it.
|-- kk.zip | |-- kk.py
When submit spark job, add
kk.zip will be distributed with the main scrip file, and
kk.zip will be inserted at the beginning of
PATH environment variable.
Then you can use
import kk in your main script file.
This utilize Python’s zip import feature. For more information, check this link: zipimport
You can also upload zip file to hdfs, and using
SparkContext is initialized.
This has the same effect as
--py-files, but your import statement must be after this line.