AccidentAnalysis

This repository contain Accident Analysis pipeline build in Pyspark.

Building for source

make build

Executing particular pipeline

spark-submit \
--py-files jobs.zip,shared.zip \
--files config.json \
main.py --job <job_id>