Skip to content

Commit ffdb41d

Browse files
committed
Fixes #26
Adds typealias `org.jetbrains.spark.api.SparkSession` to `org.apache.spark.sql.SparkSession` Signed-off-by: Pasha Finkelshteyn <asm0dey@jetbrains.com>
1 parent f039e5d commit ffdb41d

File tree

2 files changed

+2
-1
lines changed
  • examples/src/main/kotlin/org/jetbrains/spark/api/examples
  • kotlin-spark-api/src/main/kotlin/org/jetbrains/spark/api

2 files changed

+2
-1
lines changed

examples/src/main/kotlin/org/jetbrains/spark/api/examples/Main.kt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
package org.jetbrains.spark.api.examples
2121

2222
import org.apache.spark.api.java.function.ReduceFunction
23-
import org.apache.spark.sql.SparkSession
2423
import org.jetbrains.spark.api.*
2524

2625
data class Q<T>(val id: Int, val text: T)

kotlin-spark-api/src/main/kotlin/org/jetbrains/spark/api/ApiV1.kt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -299,6 +299,8 @@ fun schema(type: KType, map: Map<String, KType> = mapOf()): DataType {
299299
}
300300
}
301301

302+
typealias SparkSession = org.apache.spark.sql.SparkSession
303+
302304
fun SparkContext.setLogLevel(level: SparkLogLevel) = setLogLevel(level.name)
303305

304306
enum class SparkLogLevel {

0 commit comments

Comments
 (0)