spark 3.4/3.5 compatibility issue with ProductEncoder

Kotlin · Mar 25, 2024 · 37eec64 · 37eec64
1 parent 0db290a
commit 37eec64
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/kotlin-spark-api/src/main/kotlin/org/jetbrains/kotlinx/spark/api/Encoding.kt b/kotlin-spark-api/src/main/kotlin/org/jetbrains/kotlinx/spark/api/Encoding.kt
@@ -532,7 +532,9 @@ object KotlinTypeInference : Serializable {
                 ProductEncoder<Any>(
                     /* clsTag = */ ClassTag.apply(jClass),
                     /* fields = */ params.asScalaSeq(),
+                    //#if sparkMinor >= 3.5
                     /* outerPointerGetter = */ OuterScopes.getOuterScope(jClass).toOption(),
+                    //#endif
                 )
             }
 
@@ -558,7 +560,9 @@ object KotlinTypeInference : Serializable {
                 ProductEncoder<Any>(
                     /* clsTag = */ ClassTag.apply(jClass),
                     /* fields = */ params.asScalaSeq(),
+                    //#if sparkMinor >= 3.5
                     /* outerPointerGetter = */ OuterScopes.getOuterScope(jClass).toOption(),
+                    //#endif
                 )
             }