diff --git a/build.sbt b/build.sbt index 6bc70f2..6b12ce8 100644 --- a/build.sbt +++ b/build.sbt @@ -1,4 +1,4 @@ -ThisBuild / organization := "data.cartel" +ThisBuild / organization := "data.clique" ThisBuild / version := "0.1.0" ThisBuild / resolvers ++= Seq( "s01-oss-sonatype".at("https://s01.oss.sonatype.org/content/repositories/snapshots"), @@ -60,7 +60,7 @@ lazy val sparcala = (project in file("sparcala")) "org.apache.spark" %% "spark-streaming-kafka-0-10" % SparkVersion // "org.apache.kafka" % "kafka-streams" % KafkaVersion ), - assembly / mainClass := Some("data.cartel.sparcala.Sparcala"), + assembly / mainClass := Some("data.clique.sparcala.Sparcala"), assembly / assemblyJarName := "sparcala.jar", assembly / assemblyMergeStrategy := { case PathList("META-INF", "services", xs @ _*) => MergeStrategy.filterDistinctLines diff --git a/sparcala/src/main/scala/data/cartel/sparcala/Sparcala.scala b/sparcala/src/main/scala/data/clique/sparcala/Sparcala.scala similarity index 97% rename from sparcala/src/main/scala/data/cartel/sparcala/Sparcala.scala rename to sparcala/src/main/scala/data/clique/sparcala/Sparcala.scala index 741c473..85c76a3 100644 --- a/sparcala/src/main/scala/data/cartel/sparcala/Sparcala.scala +++ b/sparcala/src/main/scala/data/clique/sparcala/Sparcala.scala @@ -1,4 +1,4 @@ -package data.cartel.sparcala +package data.clique.sparcala import org.apache.spark.SparkConf import org.apache.spark.sql.SparkSession diff --git a/spark.nix b/spark.nix index 730fbeb..2901744 100644 --- a/spark.nix +++ b/spark.nix @@ -60,7 +60,7 @@ scalapuff = '' ${pkgs.sbt}/bin/sbt assembly \ && ${pkg}/bin/spark-submit \ - --class data.cartel.sparcala.Sparcala \ + --class data.clique.sparcala.Sparcala \ --master spark://${env.SPARK_MASTER_HOST}:${env.SPARK_MASTER_PORT} \ sparcala/target/scala-2.13/sparcala.jar '';