File tree Expand file tree Collapse file tree 2 files changed +3
-4
lines changed
main/scala/org/apache/spark/sql/hive
test/scala/org/apache/spark/sql/hive/execution Expand file tree Collapse file tree 2 files changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -340,7 +340,7 @@ private[hive] case class HiveUDAFFunction(
340340 resolver.getEvaluator(parameterInfo)
341341 }
342342
343- case class Mode (evaluator : GenericUDAFEvaluator , objectInspector : ObjectInspector )
343+ private case class Mode (evaluator : GenericUDAFEvaluator , objectInspector : ObjectInspector )
344344
345345 // The UDAF evaluator used to consume raw input rows and produce partial aggregation results.
346346 // Hive `ObjectInspector` used to inspect partial aggregation results.
Original file line number Diff line number Diff line change @@ -639,10 +639,9 @@ class HiveUDFSuite extends QueryTest with TestHiveSingleton with SQLTestUtils {
639639 }
640640 }
641641
642- test(" constant argument expecting Hive UDF" ) {
643- val testData = spark.range(10 ).toDF()
642+ test(" SPARK-25768 constant argument expecting Hive UDF" ) {
644643 withTempView(" inputTable" ) {
645- testData .createOrReplaceTempView(" inputTable" )
644+ spark.range( 10 ) .createOrReplaceTempView(" inputTable" )
646645 withUserDefinedFunction(" testGenericUDAFPercentileApprox" -> false ) {
647646 val numFunc = spark.catalog.listFunctions().count()
648647 sql(s " CREATE FUNCTION testGenericUDAFPercentileApprox AS ' " +
You can’t perform that action at this time.
0 commit comments