Slackbot
08/23/2023, 9:50 AMJulien Jakubowski
08/23/2023, 10:08 AMbuilt.sbt file. Here is an example:
val sparkVersion = "3.4.1"
val pulsarVersion = "3.1.0"
libraryDependencies ++= Seq(
"org.apache.spark" %% "spark-core" % sparkVersion,
"org.apache.spark" %% "spark-sql" % sparkVersion,
"org.apache.spark" %% "spark-streaming" % sparkVersion,
"org.apache.pulsar" % "pulsar-client" % pulsarVersion,
"org.apache.pulsar" %% "pulsar-spark" % pulsarVersion
)
Hope that helpsJulien Jakubowski
08/23/2023, 10:14 AMcustomersJulien Jakubowski
08/23/2023, 10:16 AM<persistent://public/default/customers>FizzaAbid
08/23/2023, 10:25 AM