Skip to content

Commit

Permalink
(re)moving some stuff from the decoupled :core module
Browse files Browse the repository at this point in the history
  • Loading branch information
Jolanrensen committed Mar 17, 2024
1 parent cda9548 commit 42ba339
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 878 deletions.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -26,12 +26,6 @@ import scala.reflect.ClassTag

object KSparkExtensions {

val kotlinVersion = /*$"\""+kotlin+"\""$*/ /*-*/ ""
val scalaVersion = /*$"\""+scala+"\""$*/ /*-*/ ""
val scalaCompatVersion = /*$"\""+scalaCompat+"\""$*/ /*-*/ ""
val sparkVersion = /*$"\""+spark+"\""$*/ /*-*/ ""
val sparkMinorVersion = /*$"\""+sparkMinor+"\""$*/ /*-*/ ""

def col(d: Dataset[_], name: String): Column = d.col(name)

def col(name: String): Column = functions.col(name)
Expand All @@ -46,19 +40,6 @@ object KSparkExtensions {
//#endif
}


def debugCodegen(df: Dataset[_]): Unit = {
import org.apache.spark.sql.execution.debug._
df.debugCodegen()
}

def debug(df: Dataset[_]): Unit = {
import org.apache.spark.sql.execution.debug._
df.debug()
}

def sparkContext(s: SparkSession): SparkContext = s.sparkContext

/**
* Produces a ClassTag[T], which is actually just a casted ClassTag[AnyRef].
*
Expand Down
Loading

0 comments on commit 42ba339

Please sign in to comment.