Skip to content

Commit

Permalink
disabled unsupported rddtests
Browse files Browse the repository at this point in the history
  • Loading branch information
Jolanrensen committed May 18, 2024
1 parent 92b699d commit eae0196
Showing 1 changed file with 5 additions and 2 deletions.
Original file line number Diff line number Diff line change
@@ -1,14 +1,16 @@
package org.jetbrains.kotlinx.spark.api

import io.kotest.core.spec.style.ShouldSpec
import io.kotest.core.spec.style.Test
import io.kotest.core.test.TestScope
import io.kotest.matchers.collections.shouldContainAll
import io.kotest.matchers.shouldBe
import org.apache.spark.api.java.JavaRDD
import org.jetbrains.kotlinx.spark.api.tuples.*
import scala.Tuple2
import java.io.Serializable

class RddTest : Serializable, ShouldSpec({
class RddTest : ShouldSpec({
context("RDD extension functions") {

withSpark(
Expand Down Expand Up @@ -74,6 +76,7 @@ class RddTest : Serializable, ShouldSpec({
rdd.min() shouldBe 1.0
}

// TODO Does not work from testing environment
xcontext("Work with any number") {

should("Work with Bytes") {
Expand Down Expand Up @@ -108,7 +111,7 @@ class RddTest : Serializable, ShouldSpec({

should("Work with Doubles") {
val data = listOf(1, 1, 2, 2, 2, 3).map(Int::toDouble)
val rdd = data.toRDD().toJavaDoubleRDD()
val rdd = data.toRDD()
rdd.sum() shouldBe data.sum().toDouble()
}
}
Expand Down

0 comments on commit eae0196

Please sign in to comment.