Advertisement
Guest User

Untitled

a guest
Jun 27th, 2019
69
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.92 KB | None | 0 0
  1. val sparkVersion = "2.4.3"
  2. val jacksonVersion = "2.8.7"
  3.  
  4. dependencyOverrides ++= Seq(
  5. "com.fasterxml.jackson.core" % "jackson-core" % jacksonVersion,
  6. "com.fasterxml.jackson.core" % "jackson-databind" % jacksonVersion,
  7. "com.fasterxml.jackson.module" %% "jackson-module-scala" % jacksonVersion
  8. )
  9.  
  10.  
  11. libraryDependencies ++= Seq(
  12. "org.apache.spark" %% "spark-core" % sparkVersion % "provided" ,
  13. "org.apache.spark" %% "spark-sql" % sparkVersion % "provided",
  14. "org.apache.spark" %% "spark-hive" % sparkVersion % "provided",
  15. "org.apache.spark" %% "spark-avro" % "2.4.3",
  16. "io.confluent" % "kafka-avro-serializer" % "5.0.1",
  17. "org.apache.avro" % "avro" % "1.8.2"
  18. )
  19.  
  20. assemblyMergeStrategy in assembly := {
  21. case PathList("META-INF", xs@_*) => MergeStrategy.discard
  22. case x => MergeStrategy.first
  23. }
  24.  
  25. Seq(1, 2, 3).toDF("id")
  26. .write
  27. .format("avro")
  28. .mode(SaveMode.Overwrite)
  29. .save("testavro")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement