From 37eec64e3358563a0d33852bc4377fe35cb09037 Mon Sep 17 00:00:00 2001 From: Jolan Rensen Date: Mon, 25 Mar 2024 23:20:24 +0100 Subject: [PATCH] spark 3.4/3.5 compatibility issue with ProductEncoder --- .../main/kotlin/org/jetbrains/kotlinx/spark/api/Encoding.kt | 4 ++++ 1 file changed, 4 insertions(+) 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 index 62e46676..072f4a2a 100644 --- 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( /* 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( /* clsTag = */ ClassTag.apply(jClass), /* fields = */ params.asScalaSeq(), + //#if sparkMinor >= 3.5 /* outerPointerGetter = */ OuterScopes.getOuterScope(jClass).toOption(), + //#endif ) }