Skip to content

Commit eb9a7fc

Browse files
committed
fix.
1 parent deb82f6 commit eb9a7fc

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

sql/core/src/test/java/test/org/apache/spark/sql/JavaRandUDF.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,4 +27,4 @@ public class JavaRandUDF implements UDF1<Integer, Double> {
2727
public Double call(Integer i) {
2828
return i + Math.random();
2929
}
30-
}
30+
}

sql/core/src/test/java/test/org/apache/spark/sql/JavaUDFSuite.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ public Double call(Integer i) {
134134
@Test
135135
public void udf7Test() {
136136
spark.udf().registerJava(
137-
"randUDF", randUDFTest.class.getName(), DataTypes.DoubleType, false, false);
137+
"randUDF", randUDFTest.class.getName(), DataTypes.DoubleType, false, false);
138138

139139
Row result = spark.sql("SELECT randUDF(1)").head();
140140
Assert.assertTrue(result.getDouble(0) >= 0.0);
@@ -144,11 +144,11 @@ public void udf7Test() {
144144
@Test
145145
public void udf8Test() {
146146
spark.udf().register(
147-
"randUDF", (Integer i) -> i + Math.random(), DataTypes.DoubleType, false, false);
147+
"randUDF", (Integer i) -> i + Math.random(), DataTypes.DoubleType, false, false);
148148

149149
Row result = spark.sql("SELECT randUDF(1)").head();
150150
Assert.assertTrue(result.getDouble(0) >= 0.0);
151151
Assert.assertTrue("EXPLAIN outputs are expected to contain the UDF name.",
152-
spark.sql("EXPLAIN SELECT randUDF(1) AS r").collectAsList().toString().contains("randUDF"));
152+
spark.sql("EXPLAIN SELECT randUDF(1) AS r").collectAsList().toString().contains("randUDF"));
153153
}
154154
}

0 commit comments

Comments
 (0)