Skip to content

Commit a7806aa

Browse files
committed
review changes
1 parent b80b13a commit a7806aa

File tree

3 files changed

+4
-12
lines changed

3 files changed

+4
-12
lines changed

project/SparkVersionAxis.scala

Lines changed: 4 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -29,14 +29,12 @@ import Dependencies._
2929

3030
case class SparkVersionAxis(sparkVersion: String) extends sbt.VirtualAxis.WeakAxis {
3131
val sparkVersionMinor: String = sparkVersion.split("\\.", 3).take(2).mkString(".")
32+
val sparkVersionMajor: String = sparkVersion.split("\\.", 3).take(1)(0)
3233

33-
// we have separate directory for Spark 2.4 (potentially other 2.x in the future)
34-
// and a common one for all Spark 3.x versions
35-
override val directorySuffix: String = if (sparkVersion.startsWith("2")) s"-spark${sparkVersionMinor}" else "-spark3"
34+
override val directorySuffix: String = s"-spark${sparkVersionMajor}"
3635

3736
// must be unique for all Spark versions for a given Scala version
38-
// since we share common folder for all Spark 3.x versions we cannot use directory suffix here
39-
override val idSuffix: String = s"-spark${sparkVersion.replaceAll("""\W+""", "_")}"
37+
override val idSuffix: String = s"-spark${sparkVersionMinor.replaceAll("""\W+""", "_")}"
4038
}
4139

4240

@@ -56,13 +54,7 @@ object SparkVersionAxis {
5654
_.settings(
5755
// must be defined to avoid conflicting target paths for individual spark versions' builds
5856
target := (ThisBuild / baseDirectory).value / "target" / s"${camelCaseToLowerDashCase(name.value)}${sparkAxis.sparkVersion}-jvm-${scalaVersion.value.replaceAll("""\W+""", "_")}",
59-
moduleName := {
60-
val baseName = camelCaseToLowerDashCase(name.value)
61-
if (sparkAxis.sparkVersion.startsWith("2"))
62-
baseName + sparkAxis.directorySuffix
63-
else
64-
baseName + s"-spark${sparkAxis.sparkVersionMinor}"
65-
},
57+
moduleName := camelCaseToLowerDashCase(name.value + s"-spark${sparkAxis.sparkVersionMinor}"),
6658
libraryDependencies ++= sparkCommonsDependencies(sparkAxis.sparkVersion)
6759
).settings(settings: _*)
6860
)

spark-commons/src/main/scala-spark2.4-jvm/za/co/absa/spark/commons/adapters/CallUdfAdapter.scala renamed to spark-commons/src/main/scala-spark2-jvm/za/co/absa/spark/commons/adapters/CallUdfAdapter.scala

File renamed without changes.

spark-commons/src/main/scala-spark2.4-jvm/za/co/absa/spark/commons/adapters/TransformAdapter.scala renamed to spark-commons/src/main/scala-spark2-jvm/za/co/absa/spark/commons/adapters/TransformAdapter.scala

File renamed without changes.

0 commit comments

Comments
 (0)