Answers for "spark write partitionby"

0

spark write partitionby

import spark.implicits._
df.repartition($"entity", $"year", $"month", $"day", $"status").write.partitionBy("entity", "year", "month", "day", "status").mode(SaveMode.Append).parquet(s"$location")
Posted by: Guest on June-22-2020

Code answers related to "Java"

Java Answers by Framework

Browse Popular Code Answers by Language