You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2015/06/30 00:27:26 UTC
[4/4] spark git commit: [SPARK-8478] [SQL] Harmonize UDF-related code
to use uniformly UDF instead of Udf
[SPARK-8478] [SQL] Harmonize UDF-related code to use uniformly UDF instead of Udf
Follow-up of #6902 for being coherent between ```Udf``` and ```UDF```
Author: BenFradet <be...@gmail.com>
Closes #6920 from BenFradet/SPARK-8478 and squashes the following commits:
c500f29 [BenFradet] renamed a few variables in functions to use UDF
8ab0f2d [BenFradet] renamed idUdf to idUDF in SQLQuerySuite
98696c2 [BenFradet] renamed originalUdfs in TestHive to originalUDFs
7738f74 [BenFradet] modified HiveUDFSuite to use only UDF
c52608d [BenFradet] renamed HiveUdfSuite to HiveUDFSuite
e51b9ac [BenFradet] renamed ExtractPythonUdfs to ExtractPythonUDFs
8c756f1 [BenFradet] renamed Hive UDF related code
2a1ca76 [BenFradet] renamed pythonUdfs to pythonUDFs
261e6fb [BenFradet] renamed ScalaUdf to ScalaUDF
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/931da5c8
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/931da5c8
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/931da5c8
Branch: refs/heads/master
Commit: 931da5c8ab271ff2ee04419c7e3c6b0012459694
Parents: c8ae887
Author: BenFradet <be...@gmail.com>
Authored: Mon Jun 29 15:27:13 2015 -0700
Committer: Michael Armbrust <mi...@databricks.com>
Committed: Mon Jun 29 15:27:13 2015 -0700
----------------------------------------------------------------------
.../sql/catalyst/expressions/ScalaUDF.scala | 962 +++++++++++++++++++
.../sql/catalyst/expressions/ScalaUdf.scala | 962 -------------------
.../scala/org/apache/spark/sql/SQLContext.scala | 4 +-
.../org/apache/spark/sql/UDFRegistration.scala | 96 +-
.../apache/spark/sql/UserDefinedFunction.scala | 4 +-
.../apache/spark/sql/execution/pythonUDFs.scala | 292 ++++++
.../apache/spark/sql/execution/pythonUdfs.scala | 292 ------
.../scala/org/apache/spark/sql/functions.scala | 34 +-
.../org/apache/spark/sql/SQLQuerySuite.scala | 4 +-
.../org/apache/spark/sql/hive/HiveContext.scala | 4 +-
.../org/apache/spark/sql/hive/HiveQl.scala | 2 +-
.../org/apache/spark/sql/hive/hiveUDFs.scala | 598 ++++++++++++
.../org/apache/spark/sql/hive/hiveUdfs.scala | 598 ------------
.../apache/spark/sql/hive/test/TestHive.scala | 4 +-
.../resources/data/files/testUDF/part-00000 | Bin 0 -> 153 bytes
.../resources/data/files/testUdf/part-00000 | Bin 153 -> 0 bytes
.../spark/sql/hive/execution/HiveUDFSuite.scala | 261 +++++
.../spark/sql/hive/execution/HiveUdfSuite.scala | 261 -----
18 files changed, 2189 insertions(+), 2189 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/931da5c8/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala
----------------------------------------------------------------------
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala
new file mode 100644
index 0000000..dbb4381
--- /dev/null
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala
@@ -0,0 +1,962 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.spark.sql.catalyst.expressions
+
+import org.apache.spark.sql.catalyst.CatalystTypeConverters
+import org.apache.spark.sql.types.DataType
+
+/**
+ * User-defined function.
+ * @param dataType Return type of function.
+ */
+case class ScalaUDF(function: AnyRef, dataType: DataType, children: Seq[Expression])
+ extends Expression {
+
+ override def nullable: Boolean = true
+
+ override def toString: String = s"scalaUDF(${children.mkString(",")})"
+
+ // scalastyle:off
+
+ /** This method has been generated by this script
+
+ (1 to 22).map { x =>
+ val anys = (1 to x).map(x => "Any").reduce(_ + ", " + _)
+ val childs = (0 to x - 1).map(x => s"val child$x = children($x)").reduce(_ + "\n " + _)
+ val converters = (0 to x - 1).map(x => s"lazy val converter$x = CatalystTypeConverters.createToScalaConverter(child$x.dataType)").reduce(_ + "\n " + _)
+ val evals = (0 to x - 1).map(x => s"converter$x(child$x.eval(input))").reduce(_ + ",\n " + _)
+
+ s"""case $x =>
+ val func = function.asInstanceOf[($anys) => Any]
+ $childs
+ $converters
+ (input: InternalRow) => {
+ func(
+ $evals)
+ }
+ """
+ }.foreach(println)
+
+ */
+
+ private[this] val f = children.size match {
+ case 0 =>
+ val func = function.asInstanceOf[() => Any]
+ (input: InternalRow) => {
+ func()
+ }
+
+ case 1 =>
+ val func = function.asInstanceOf[(Any) => Any]
+ val child0 = children(0)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)))
+ }
+
+ case 2 =>
+ val func = function.asInstanceOf[(Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)))
+ }
+
+ case 3 =>
+ val func = function.asInstanceOf[(Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)))
+ }
+
+ case 4 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)))
+ }
+
+ case 5 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)))
+ }
+
+ case 6 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)))
+ }
+
+ case 7 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)))
+ }
+
+ case 8 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)))
+ }
+
+ case 9 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)))
+ }
+
+ case 10 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)))
+ }
+
+ case 11 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)))
+ }
+
+ case 12 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)))
+ }
+
+ case 13 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ val child12 = children(12)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ lazy val converter12 = CatalystTypeConverters.createToScalaConverter(child12.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)),
+ converter12(child12.eval(input)))
+ }
+
+ case 14 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ val child12 = children(12)
+ val child13 = children(13)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ lazy val converter12 = CatalystTypeConverters.createToScalaConverter(child12.dataType)
+ lazy val converter13 = CatalystTypeConverters.createToScalaConverter(child13.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)),
+ converter12(child12.eval(input)),
+ converter13(child13.eval(input)))
+ }
+
+ case 15 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ val child12 = children(12)
+ val child13 = children(13)
+ val child14 = children(14)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ lazy val converter12 = CatalystTypeConverters.createToScalaConverter(child12.dataType)
+ lazy val converter13 = CatalystTypeConverters.createToScalaConverter(child13.dataType)
+ lazy val converter14 = CatalystTypeConverters.createToScalaConverter(child14.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)),
+ converter12(child12.eval(input)),
+ converter13(child13.eval(input)),
+ converter14(child14.eval(input)))
+ }
+
+ case 16 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ val child12 = children(12)
+ val child13 = children(13)
+ val child14 = children(14)
+ val child15 = children(15)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ lazy val converter12 = CatalystTypeConverters.createToScalaConverter(child12.dataType)
+ lazy val converter13 = CatalystTypeConverters.createToScalaConverter(child13.dataType)
+ lazy val converter14 = CatalystTypeConverters.createToScalaConverter(child14.dataType)
+ lazy val converter15 = CatalystTypeConverters.createToScalaConverter(child15.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)),
+ converter12(child12.eval(input)),
+ converter13(child13.eval(input)),
+ converter14(child14.eval(input)),
+ converter15(child15.eval(input)))
+ }
+
+ case 17 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ val child12 = children(12)
+ val child13 = children(13)
+ val child14 = children(14)
+ val child15 = children(15)
+ val child16 = children(16)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ lazy val converter12 = CatalystTypeConverters.createToScalaConverter(child12.dataType)
+ lazy val converter13 = CatalystTypeConverters.createToScalaConverter(child13.dataType)
+ lazy val converter14 = CatalystTypeConverters.createToScalaConverter(child14.dataType)
+ lazy val converter15 = CatalystTypeConverters.createToScalaConverter(child15.dataType)
+ lazy val converter16 = CatalystTypeConverters.createToScalaConverter(child16.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)),
+ converter12(child12.eval(input)),
+ converter13(child13.eval(input)),
+ converter14(child14.eval(input)),
+ converter15(child15.eval(input)),
+ converter16(child16.eval(input)))
+ }
+
+ case 18 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ val child12 = children(12)
+ val child13 = children(13)
+ val child14 = children(14)
+ val child15 = children(15)
+ val child16 = children(16)
+ val child17 = children(17)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ lazy val converter12 = CatalystTypeConverters.createToScalaConverter(child12.dataType)
+ lazy val converter13 = CatalystTypeConverters.createToScalaConverter(child13.dataType)
+ lazy val converter14 = CatalystTypeConverters.createToScalaConverter(child14.dataType)
+ lazy val converter15 = CatalystTypeConverters.createToScalaConverter(child15.dataType)
+ lazy val converter16 = CatalystTypeConverters.createToScalaConverter(child16.dataType)
+ lazy val converter17 = CatalystTypeConverters.createToScalaConverter(child17.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)),
+ converter12(child12.eval(input)),
+ converter13(child13.eval(input)),
+ converter14(child14.eval(input)),
+ converter15(child15.eval(input)),
+ converter16(child16.eval(input)),
+ converter17(child17.eval(input)))
+ }
+
+ case 19 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ val child12 = children(12)
+ val child13 = children(13)
+ val child14 = children(14)
+ val child15 = children(15)
+ val child16 = children(16)
+ val child17 = children(17)
+ val child18 = children(18)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ lazy val converter12 = CatalystTypeConverters.createToScalaConverter(child12.dataType)
+ lazy val converter13 = CatalystTypeConverters.createToScalaConverter(child13.dataType)
+ lazy val converter14 = CatalystTypeConverters.createToScalaConverter(child14.dataType)
+ lazy val converter15 = CatalystTypeConverters.createToScalaConverter(child15.dataType)
+ lazy val converter16 = CatalystTypeConverters.createToScalaConverter(child16.dataType)
+ lazy val converter17 = CatalystTypeConverters.createToScalaConverter(child17.dataType)
+ lazy val converter18 = CatalystTypeConverters.createToScalaConverter(child18.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)),
+ converter12(child12.eval(input)),
+ converter13(child13.eval(input)),
+ converter14(child14.eval(input)),
+ converter15(child15.eval(input)),
+ converter16(child16.eval(input)),
+ converter17(child17.eval(input)),
+ converter18(child18.eval(input)))
+ }
+
+ case 20 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ val child12 = children(12)
+ val child13 = children(13)
+ val child14 = children(14)
+ val child15 = children(15)
+ val child16 = children(16)
+ val child17 = children(17)
+ val child18 = children(18)
+ val child19 = children(19)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ lazy val converter12 = CatalystTypeConverters.createToScalaConverter(child12.dataType)
+ lazy val converter13 = CatalystTypeConverters.createToScalaConverter(child13.dataType)
+ lazy val converter14 = CatalystTypeConverters.createToScalaConverter(child14.dataType)
+ lazy val converter15 = CatalystTypeConverters.createToScalaConverter(child15.dataType)
+ lazy val converter16 = CatalystTypeConverters.createToScalaConverter(child16.dataType)
+ lazy val converter17 = CatalystTypeConverters.createToScalaConverter(child17.dataType)
+ lazy val converter18 = CatalystTypeConverters.createToScalaConverter(child18.dataType)
+ lazy val converter19 = CatalystTypeConverters.createToScalaConverter(child19.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)),
+ converter12(child12.eval(input)),
+ converter13(child13.eval(input)),
+ converter14(child14.eval(input)),
+ converter15(child15.eval(input)),
+ converter16(child16.eval(input)),
+ converter17(child17.eval(input)),
+ converter18(child18.eval(input)),
+ converter19(child19.eval(input)))
+ }
+
+ case 21 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ val child12 = children(12)
+ val child13 = children(13)
+ val child14 = children(14)
+ val child15 = children(15)
+ val child16 = children(16)
+ val child17 = children(17)
+ val child18 = children(18)
+ val child19 = children(19)
+ val child20 = children(20)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ lazy val converter12 = CatalystTypeConverters.createToScalaConverter(child12.dataType)
+ lazy val converter13 = CatalystTypeConverters.createToScalaConverter(child13.dataType)
+ lazy val converter14 = CatalystTypeConverters.createToScalaConverter(child14.dataType)
+ lazy val converter15 = CatalystTypeConverters.createToScalaConverter(child15.dataType)
+ lazy val converter16 = CatalystTypeConverters.createToScalaConverter(child16.dataType)
+ lazy val converter17 = CatalystTypeConverters.createToScalaConverter(child17.dataType)
+ lazy val converter18 = CatalystTypeConverters.createToScalaConverter(child18.dataType)
+ lazy val converter19 = CatalystTypeConverters.createToScalaConverter(child19.dataType)
+ lazy val converter20 = CatalystTypeConverters.createToScalaConverter(child20.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)),
+ converter12(child12.eval(input)),
+ converter13(child13.eval(input)),
+ converter14(child14.eval(input)),
+ converter15(child15.eval(input)),
+ converter16(child16.eval(input)),
+ converter17(child17.eval(input)),
+ converter18(child18.eval(input)),
+ converter19(child19.eval(input)),
+ converter20(child20.eval(input)))
+ }
+
+ case 22 =>
+ val func = function.asInstanceOf[(Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any) => Any]
+ val child0 = children(0)
+ val child1 = children(1)
+ val child2 = children(2)
+ val child3 = children(3)
+ val child4 = children(4)
+ val child5 = children(5)
+ val child6 = children(6)
+ val child7 = children(7)
+ val child8 = children(8)
+ val child9 = children(9)
+ val child10 = children(10)
+ val child11 = children(11)
+ val child12 = children(12)
+ val child13 = children(13)
+ val child14 = children(14)
+ val child15 = children(15)
+ val child16 = children(16)
+ val child17 = children(17)
+ val child18 = children(18)
+ val child19 = children(19)
+ val child20 = children(20)
+ val child21 = children(21)
+ lazy val converter0 = CatalystTypeConverters.createToScalaConverter(child0.dataType)
+ lazy val converter1 = CatalystTypeConverters.createToScalaConverter(child1.dataType)
+ lazy val converter2 = CatalystTypeConverters.createToScalaConverter(child2.dataType)
+ lazy val converter3 = CatalystTypeConverters.createToScalaConverter(child3.dataType)
+ lazy val converter4 = CatalystTypeConverters.createToScalaConverter(child4.dataType)
+ lazy val converter5 = CatalystTypeConverters.createToScalaConverter(child5.dataType)
+ lazy val converter6 = CatalystTypeConverters.createToScalaConverter(child6.dataType)
+ lazy val converter7 = CatalystTypeConverters.createToScalaConverter(child7.dataType)
+ lazy val converter8 = CatalystTypeConverters.createToScalaConverter(child8.dataType)
+ lazy val converter9 = CatalystTypeConverters.createToScalaConverter(child9.dataType)
+ lazy val converter10 = CatalystTypeConverters.createToScalaConverter(child10.dataType)
+ lazy val converter11 = CatalystTypeConverters.createToScalaConverter(child11.dataType)
+ lazy val converter12 = CatalystTypeConverters.createToScalaConverter(child12.dataType)
+ lazy val converter13 = CatalystTypeConverters.createToScalaConverter(child13.dataType)
+ lazy val converter14 = CatalystTypeConverters.createToScalaConverter(child14.dataType)
+ lazy val converter15 = CatalystTypeConverters.createToScalaConverter(child15.dataType)
+ lazy val converter16 = CatalystTypeConverters.createToScalaConverter(child16.dataType)
+ lazy val converter17 = CatalystTypeConverters.createToScalaConverter(child17.dataType)
+ lazy val converter18 = CatalystTypeConverters.createToScalaConverter(child18.dataType)
+ lazy val converter19 = CatalystTypeConverters.createToScalaConverter(child19.dataType)
+ lazy val converter20 = CatalystTypeConverters.createToScalaConverter(child20.dataType)
+ lazy val converter21 = CatalystTypeConverters.createToScalaConverter(child21.dataType)
+ (input: InternalRow) => {
+ func(
+ converter0(child0.eval(input)),
+ converter1(child1.eval(input)),
+ converter2(child2.eval(input)),
+ converter3(child3.eval(input)),
+ converter4(child4.eval(input)),
+ converter5(child5.eval(input)),
+ converter6(child6.eval(input)),
+ converter7(child7.eval(input)),
+ converter8(child8.eval(input)),
+ converter9(child9.eval(input)),
+ converter10(child10.eval(input)),
+ converter11(child11.eval(input)),
+ converter12(child12.eval(input)),
+ converter13(child13.eval(input)),
+ converter14(child14.eval(input)),
+ converter15(child15.eval(input)),
+ converter16(child16.eval(input)),
+ converter17(child17.eval(input)),
+ converter18(child18.eval(input)),
+ converter19(child19.eval(input)),
+ converter20(child20.eval(input)),
+ converter21(child21.eval(input)))
+ }
+ }
+
+ // scalastyle:on
+ private[this] val converter = CatalystTypeConverters.createToCatalystConverter(dataType)
+ override def eval(input: InternalRow): Any = converter(f(input))
+
+ // TODO(davies): make ScalaUDF work with codegen
+ override def isThreadSafe: Boolean = false
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org