SPARK-11716 - Update the script used to generate register() functions

jbonofre · jbonofre · commit 3ebf48728898 · 2015-11-18T15:05:25.000+01:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala b/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala
@@ -88,7 +88,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
           val inputTypes = Try($inputTypes).getOrElse(Nil)
           def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
           functionRegistry.registerFunction(name, builder)
-          UserDefinedFunction(func, dataType)
+          UserDefinedFunction(func, dataType, inputTypes)
         }""")
     }
 

Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {`
`88`	`88`	`val inputTypes = Try($inputTypes).getOrElse(Nil)`
`89`	`89`	`def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)`
`90`	`90`	`functionRegistry.registerFunction(name, builder)`
`91`		`- UserDefinedFunction(func, dataType)`
	`91`	`+ UserDefinedFunction(func, dataType, inputTypes)`
`92`	`92`	`}""")`
`93`	`93`	`}`
`94`	`94`