PySpark

How to add dependencies as jar files or Python scripts to PySpark

How to add a jar file or a Python file as a Pyspark dependency

Bartosz Mikulski 21 Dec 2020 – 1 min read

When we want to use external dependencies in the PySpark code, we have two options. We can either pass them as jar files or Python scripts.

In this article, I will show how to do that when running a PySpark job using AWS EMR. The jar and Python files will be stored on S3 in a location accessible from the EMR cluster (remember to set the permissions).

First, we have to add the --jars and --py-files parameters to the spark-submit command while starting a new PySpark job:

spark-submit --deploy-mode cluster \
    --jars s3://some_bucket/java_code.jar \
    --py-files s3://some_bucket/python_code.py \
    s3://some_bucket/pyspark_job.py

In the pyspark_job.py file, I can import the code from the jar file just like any other dependency.

import python_code.something

Older post

How to add dependencies as jar files or Python scripts to PySpark

How to reset the consumer offset in Apache Kafka topic

How to write to a SQL database using JDBC in PySpark

How to add dependencies as jar files or Python scripts to PySpark

How to reset the consumer offset in Apache Kafka topic

How to write to a SQL database using JDBC in PySpark

Related Posts

Testing data products: BDD for data engineers

How to read from SQL table in PySpark using a query instead of specifying a table

How to write to a SQL database using JDBC in PySpark