Fixes #26

Adds typealias `org.jetbrains.spark.api.SparkSession` to `org.apache.spark.sql.SparkSession` Signed-off-by: Pasha Finkelshteyn <[email protected]>
Kotlin · Jun 29, 2020 · ffdb41d · ffdb41d
1 parent f039e5d
commit ffdb41d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/examples/src/main/kotlin/org/jetbrains/spark/api/examples/Main.kt b/examples/src/main/kotlin/org/jetbrains/spark/api/examples/Main.kt
@@ -20,7 +20,6 @@
 package org.jetbrains.spark.api.examples
 
 import org.apache.spark.api.java.function.ReduceFunction
-import org.apache.spark.sql.SparkSession
 import org.jetbrains.spark.api.*
 
 data class Q<T>(val id: Int, val text: T)

diff --git a/kotlin-spark-api/src/main/kotlin/org/jetbrains/spark/api/ApiV1.kt b/kotlin-spark-api/src/main/kotlin/org/jetbrains/spark/api/ApiV1.kt
@@ -299,6 +299,8 @@ fun schema(type: KType, map: Map<String, KType> = mapOf()): DataType {
     }
 }
 
+typealias SparkSession = org.apache.spark.sql.SparkSession
+
 fun SparkContext.setLogLevel(level: SparkLogLevel) = setLogLevel(level.name)
 
 enum class SparkLogLevel {
-Original file line number
+Diff line change
@@ Expand Up @@
         }
     }
+    typealias SparkSession = org.apache.spark.sql.SparkSession
     fun SparkContext.setLogLevel(level: SparkLogLevel) = setLogLevel(level.name)
     enum class SparkLogLevel {
@@ Expand Down @@