Skip to content

Instantly share code, notes, and snippets.

@dardanxhymshiti

dardanxhymshiti/job_one_seed.py

Last active May 21, 2020 14:56
Show Gist options
  • Save dardanxhymshiti/63ab2570822368584b4083e605400392 to your computer and use it in GitHub Desktop.
Save dardanxhymshiti/63ab2570822368584b4083e605400392 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
job_one_seed.py
def process(spark, input_path, output_path, save_mode='append'):
# read data
df = spark.read.parquet(input_path)
# processing
pass
# output
df.write.parquet(output_path, save_mode=save_mode)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment