Skip to content

Instantly share code, notes, and snippets.

@KKcorps
Created August 14, 2020 20:54
Show Gist options
  • Save KKcorps/9accfbafbb228a2dba9d5816fcb5aeb1 to your computer and use it in GitHub Desktop.
Save KKcorps/9accfbafbb228a2dba9d5816fcb5aeb1 to your computer and use it in GitHub Desktop.
val df = spark.read.format("csv").option("header", true).load("path/to/students.csv")
df.write.option("compression","none").mode("overwrite").parquet("/path/to/batch_input/")
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment