Skip to content

Commit b9b0e17

Browse files
jbonofremarmbrus
jbonofre
authored and
marmbrus
committed
[SPARK-11716][SQL] UDFRegistration just drops the input type when re-creating the UserDefinedFunction
https://issues.apache.org/jira/browse/SPARK-11716 This is one is apache#9739 and a regression test. When commit it, please make sure the author is jbonofre. You can find the original PR at apache#9739 closes apache#9739 Author: Jean-Baptiste Onofré <jbonofre@apache.org> Author: Yin Huai <yhuai@databricks.com> Closes apache#9868 from yhuai/SPARK-11716. (cherry picked from commit 03ba56d) Signed-off-by: Michael Armbrust <michael@databricks.com>
1 parent fbe6888 commit b9b0e17

File tree

2 files changed

+39
-24
lines changed

2 files changed

+39
-24
lines changed

‎sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala

Lines changed: 24 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
8888
val inputTypes = Try($inputTypes).getOrElse(Nil)
8989
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
9090
functionRegistry.registerFunction(name, builder)
91-
UserDefinedFunction(func, dataType)
91+
UserDefinedFunction(func, dataType, inputTypes)
9292
}""")
9393
}
9494
@@ -120,7 +120,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
120120
val inputTypes = Try(Nil).getOrElse(Nil)
121121
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
122122
functionRegistry.registerFunction(name, builder)
123-
UserDefinedFunction(func, dataType)
123+
UserDefinedFunction(func, dataType, inputTypes)
124124
}
125125

126126
/**
@@ -133,7 +133,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
133133
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: Nil).getOrElse(Nil)
134134
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
135135
functionRegistry.registerFunction(name, builder)
136-
UserDefinedFunction(func, dataType)
136+
UserDefinedFunction(func, dataType, inputTypes)
137137
}
138138

139139
/**
@@ -146,7 +146,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
146146
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: Nil).getOrElse(Nil)
147147
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
148148
functionRegistry.registerFunction(name, builder)
149-
UserDefinedFunction(func, dataType)
149+
UserDefinedFunction(func, dataType, inputTypes)
150150
}
151151

152152
/**
@@ -159,7 +159,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
159159
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: Nil).getOrElse(Nil)
160160
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
161161
functionRegistry.registerFunction(name, builder)
162-
UserDefinedFunction(func, dataType)
162+
UserDefinedFunction(func, dataType, inputTypes)
163163
}
164164

165165
/**
@@ -172,7 +172,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
172172
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: Nil).getOrElse(Nil)
173173
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
174174
functionRegistry.registerFunction(name, builder)
175-
UserDefinedFunction(func, dataType)
175+
UserDefinedFunction(func, dataType, inputTypes)
176176
}
177177

178178
/**
@@ -185,7 +185,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
185185
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: Nil).getOrElse(Nil)
186186
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
187187
functionRegistry.registerFunction(name, builder)
188-
UserDefinedFunction(func, dataType)
188+
UserDefinedFunction(func, dataType, inputTypes)
189189
}
190190

191191
/**
@@ -198,7 +198,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
198198
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: Nil).getOrElse(Nil)
199199
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
200200
functionRegistry.registerFunction(name, builder)
201-
UserDefinedFunction(func, dataType)
201+
UserDefinedFunction(func, dataType, inputTypes)
202202
}
203203

204204
/**
@@ -211,7 +211,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
211211
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: Nil).getOrElse(Nil)
212212
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
213213
functionRegistry.registerFunction(name, builder)
214-
UserDefinedFunction(func, dataType)
214+
UserDefinedFunction(func, dataType, inputTypes)
215215
}
216216

217217
/**
@@ -224,7 +224,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
224224
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: Nil).getOrElse(Nil)
225225
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
226226
functionRegistry.registerFunction(name, builder)
227-
UserDefinedFunction(func, dataType)
227+
UserDefinedFunction(func, dataType, inputTypes)
228228
}
229229

230230
/**
@@ -237,7 +237,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
237237
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: Nil).getOrElse(Nil)
238238
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
239239
functionRegistry.registerFunction(name, builder)
240-
UserDefinedFunction(func, dataType)
240+
UserDefinedFunction(func, dataType, inputTypes)
241241
}
242242

243243
/**
@@ -250,7 +250,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
250250
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: Nil).getOrElse(Nil)
251251
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
252252
functionRegistry.registerFunction(name, builder)
253-
UserDefinedFunction(func, dataType)
253+
UserDefinedFunction(func, dataType, inputTypes)
254254
}
255255

256256
/**
@@ -263,7 +263,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
263263
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: Nil).getOrElse(Nil)
264264
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
265265
functionRegistry.registerFunction(name, builder)
266-
UserDefinedFunction(func, dataType)
266+
UserDefinedFunction(func, dataType, inputTypes)
267267
}
268268

269269
/**
@@ -276,7 +276,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
276276
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: Nil).getOrElse(Nil)
277277
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
278278
functionRegistry.registerFunction(name, builder)
279-
UserDefinedFunction(func, dataType)
279+
UserDefinedFunction(func, dataType, inputTypes)
280280
}
281281

282282
/**
@@ -289,7 +289,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
289289
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: ScalaReflection.schemaFor[A13].dataType :: Nil).getOrElse(Nil)
290290
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
291291
functionRegistry.registerFunction(name, builder)
292-
UserDefinedFunction(func, dataType)
292+
UserDefinedFunction(func, dataType, inputTypes)
293293
}
294294

295295
/**
@@ -302,7 +302,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
302302
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: ScalaReflection.schemaFor[A13].dataType :: ScalaReflection.schemaFor[A14].dataType :: Nil).getOrElse(Nil)
303303
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
304304
functionRegistry.registerFunction(name, builder)
305-
UserDefinedFunction(func, dataType)
305+
UserDefinedFunction(func, dataType, inputTypes)
306306
}
307307

308308
/**
@@ -315,7 +315,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
315315
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: ScalaReflection.schemaFor[A13].dataType :: ScalaReflection.schemaFor[A14].dataType :: ScalaReflection.schemaFor[A15].dataType :: Nil).getOrElse(Nil)
316316
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
317317
functionRegistry.registerFunction(name, builder)
318-
UserDefinedFunction(func, dataType)
318+
UserDefinedFunction(func, dataType, inputTypes)
319319
}
320320

321321
/**
@@ -328,7 +328,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
328328
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: ScalaReflection.schemaFor[A13].dataType :: ScalaReflection.schemaFor[A14].dataType :: ScalaReflection.schemaFor[A15].dataType :: ScalaReflection.schemaFor[A16].dataType :: Nil).getOrElse(Nil)
329329
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
330330
functionRegistry.registerFunction(name, builder)
331-
UserDefinedFunction(func, dataType)
331+
UserDefinedFunction(func, dataType, inputTypes)
332332
}
333333

334334
/**
@@ -341,7 +341,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
341341
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: ScalaReflection.schemaFor[A13].dataType :: ScalaReflection.schemaFor[A14].dataType :: ScalaReflection.schemaFor[A15].dataType :: ScalaReflection.schemaFor[A16].dataType :: ScalaReflection.schemaFor[A17].dataType :: Nil).getOrElse(Nil)
342342
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
343343
functionRegistry.registerFunction(name, builder)
344-
UserDefinedFunction(func, dataType)
344+
UserDefinedFunction(func, dataType, inputTypes)
345345
}
346346

347347
/**
@@ -354,7 +354,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
354354
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: ScalaReflection.schemaFor[A13].dataType :: ScalaReflection.schemaFor[A14].dataType :: ScalaReflection.schemaFor[A15].dataType :: ScalaReflection.schemaFor[A16].dataType :: ScalaReflection.schemaFor[A17].dataType :: ScalaReflection.schemaFor[A18].dataType :: Nil).getOrElse(Nil)
355355
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
356356
functionRegistry.registerFunction(name, builder)
357-
UserDefinedFunction(func, dataType)
357+
UserDefinedFunction(func, dataType, inputTypes)
358358
}
359359

360360
/**
@@ -367,7 +367,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
367367
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: ScalaReflection.schemaFor[A13].dataType :: ScalaReflection.schemaFor[A14].dataType :: ScalaReflection.schemaFor[A15].dataType :: ScalaReflection.schemaFor[A16].dataType :: ScalaReflection.schemaFor[A17].dataType :: ScalaReflection.schemaFor[A18].dataType :: ScalaReflection.schemaFor[A19].dataType :: Nil).getOrElse(Nil)
368368
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
369369
functionRegistry.registerFunction(name, builder)
370-
UserDefinedFunction(func, dataType)
370+
UserDefinedFunction(func, dataType, inputTypes)
371371
}
372372

373373
/**
@@ -380,7 +380,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
380380
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: ScalaReflection.schemaFor[A13].dataType :: ScalaReflection.schemaFor[A14].dataType :: ScalaReflection.schemaFor[A15].dataType :: ScalaReflection.schemaFor[A16].dataType :: ScalaReflection.schemaFor[A17].dataType :: ScalaReflection.schemaFor[A18].dataType :: ScalaReflection.schemaFor[A19].dataType :: ScalaReflection.schemaFor[A20].dataType :: Nil).getOrElse(Nil)
381381
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
382382
functionRegistry.registerFunction(name, builder)
383-
UserDefinedFunction(func, dataType)
383+
UserDefinedFunction(func, dataType, inputTypes)
384384
}
385385

386386
/**
@@ -393,7 +393,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
393393
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: ScalaReflection.schemaFor[A13].dataType :: ScalaReflection.schemaFor[A14].dataType :: ScalaReflection.schemaFor[A15].dataType :: ScalaReflection.schemaFor[A16].dataType :: ScalaReflection.schemaFor[A17].dataType :: ScalaReflection.schemaFor[A18].dataType :: ScalaReflection.schemaFor[A19].dataType :: ScalaReflection.schemaFor[A20].dataType :: ScalaReflection.schemaFor[A21].dataType :: Nil).getOrElse(Nil)
394394
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
395395
functionRegistry.registerFunction(name, builder)
396-
UserDefinedFunction(func, dataType)
396+
UserDefinedFunction(func, dataType, inputTypes)
397397
}
398398

399399
/**
@@ -406,7 +406,7 @@ class UDFRegistration private[sql] (sqlContext: SQLContext) extends Logging {
406406
val inputTypes = Try(ScalaReflection.schemaFor[A1].dataType :: ScalaReflection.schemaFor[A2].dataType :: ScalaReflection.schemaFor[A3].dataType :: ScalaReflection.schemaFor[A4].dataType :: ScalaReflection.schemaFor[A5].dataType :: ScalaReflection.schemaFor[A6].dataType :: ScalaReflection.schemaFor[A7].dataType :: ScalaReflection.schemaFor[A8].dataType :: ScalaReflection.schemaFor[A9].dataType :: ScalaReflection.schemaFor[A10].dataType :: ScalaReflection.schemaFor[A11].dataType :: ScalaReflection.schemaFor[A12].dataType :: ScalaReflection.schemaFor[A13].dataType :: ScalaReflection.schemaFor[A14].dataType :: ScalaReflection.schemaFor[A15].dataType :: ScalaReflection.schemaFor[A16].dataType :: ScalaReflection.schemaFor[A17].dataType :: ScalaReflection.schemaFor[A18].dataType :: ScalaReflection.schemaFor[A19].dataType :: ScalaReflection.schemaFor[A20].dataType :: ScalaReflection.schemaFor[A21].dataType :: ScalaReflection.schemaFor[A22].dataType :: Nil).getOrElse(Nil)
407407
def builder(e: Seq[Expression]) = ScalaUDF(func, dataType, e, inputTypes)
408408
functionRegistry.registerFunction(name, builder)
409-
UserDefinedFunction(func, dataType)
409+
UserDefinedFunction(func, dataType, inputTypes)
410410
}
411411

412412
//////////////////////////////////////////////////////////////////////////////////////////////

0 commit comments

Comments
 (0)