Skip to content

Commit b3709a1

Browse files
committed
Clean tests themselves as well
1 parent 1295633 commit b3709a1

File tree

1 file changed

+11
-19
lines changed

1 file changed

+11
-19
lines changed

sql/core/src/test/scala/org/apache/spark/sql/DataFrameNaFunctionsSuite.scala

Lines changed: 11 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -416,44 +416,36 @@ class DataFrameNaFunctionsSuite extends QueryTest with SharedSparkSession {
416416
test("replace nan with float") {
417417
checkAnswer(
418418
createNaNDF().na.replace("*", Map(
419-
Float.NaN -> 10f
419+
Float.NaN -> 10.0f
420420
)),
421-
Row(1, new java.lang.Long(1), new java.lang.Short("1"),
422-
new java.lang.Byte("1"), new java.lang.Float(1.0), 1.0) ::
423-
Row(0, new java.lang.Long(0), new java.lang.Short("0"),
424-
new java.lang.Byte("0"), new java.lang.Float(10), new java.lang.Double(10)) :: Nil)
421+
Row(1, 1L, 1.toShort, 1.toByte, 1.0f, 1.0) ::
422+
Row(0, 0L, 0.toShort, 0.toByte, 10.0f, 10.0) :: Nil)
425423
}
426424

427425
test("replace nan with double") {
428426
checkAnswer(
429427
createNaNDF().na.replace("*", Map(
430-
Double.NaN -> 10.toDouble
428+
Double.NaN -> 10.0
431429
)),
432-
Row(1, new java.lang.Long(1), new java.lang.Short("1"),
433-
new java.lang.Byte("1"), new java.lang.Float(1.0), 1.0) ::
434-
Row(0, new java.lang.Long(0), new java.lang.Short("0"),
435-
new java.lang.Byte("0"), new java.lang.Float(10), new java.lang.Double(10)) :: Nil)
430+
Row(1, 1L, 1.toShort, 1.toByte, 1.0f, 1.0) ::
431+
Row(0, 0L, 0.toShort, 0.toByte, 10.0f, 10.0) :: Nil)
436432
}
437433

438434
test("replace float with nan") {
439435
checkAnswer(
440436
createNaNDF().na.replace("*", Map(
441437
1.0f -> Float.NaN
442438
)),
443-
Row(0, new java.lang.Long(0), new java.lang.Short("0"),
444-
new java.lang.Byte("0"), java.lang.Float.NaN, java.lang.Double.NaN) ::
445-
Row(0, new java.lang.Long(0), new java.lang.Short("0"),
446-
new java.lang.Byte("0"), java.lang.Float.NaN, java.lang.Double.NaN) :: Nil)
439+
Row(0, 0L, 0.toShort, 0.toByte, Float.NaN, Double.NaN) ::
440+
Row(0, 0L, 0.toShort, 0.toByte, Float.NaN, Double.NaN) :: Nil)
447441
}
448442

449443
test("replace double with nan") {
450444
checkAnswer(
451445
createNaNDF().na.replace("*", Map(
452-
1.toDouble -> Double.NaN
446+
1.0 -> Double.NaN
453447
)),
454-
Row(0, new java.lang.Long(0), new java.lang.Short("0"),
455-
new java.lang.Byte("0"), java.lang.Float.NaN, java.lang.Double.NaN) ::
456-
Row(0, new java.lang.Long(0), new java.lang.Short("0"),
457-
new java.lang.Byte("0"), java.lang.Float.NaN, java.lang.Double.NaN) :: Nil)
448+
Row(0, 0L, 0.toShort, 0.toByte, Float.NaN, Double.NaN) ::
449+
Row(0, 0L, 0.toShort, 0.toByte, Float.NaN, Double.NaN) :: Nil)
458450
}
459451
}

0 commit comments

Comments
 (0)