Skip to content

Commit ef4e9d8

Browse files
committed
deprecated callUDF, use udf instead
1 parent 9b1de4d commit ef4e9d8

File tree

1 file changed

+24
-0
lines changed

1 file changed

+24
-0
lines changed

sql/core/src/main/scala/org/apache/spark/sql/functions.scala

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1385,7 +1385,9 @@ object functions {
13851385
*
13861386
* @group udf_funcs
13871387
* @since 1.3.0
1388+
* @deprecated As of 1.5.0, since it's redundant with udf()
13881389
*/
1390+
@deprecated("Use udf", "1.5.0")
13891391
def callUDF(f: Function$x[$fTypes], returnType: DataType${if (args.length > 0) ", " + args else ""}): Column = {
13901392
ScalaUdf(f, returnType, Seq($argsInUdf))
13911393
}""")
@@ -1521,7 +1523,9 @@ object functions {
15211523
*
15221524
* @group udf_funcs
15231525
* @since 1.3.0
1526+
* @deprecated As of 1.5.0, since it's redundant with udf()
15241527
*/
1528+
@deprecated("Use udf", "1.5.0")
15251529
def callUDF(f: Function0[_], returnType: DataType): Column = {
15261530
ScalaUdf(f, returnType, Seq())
15271531
}
@@ -1532,7 +1536,9 @@ object functions {
15321536
*
15331537
* @group udf_funcs
15341538
* @since 1.3.0
1539+
* @deprecated As of 1.5.0, since it's redundant with udf()
15351540
*/
1541+
@deprecated("Use udf", "1.5.0")
15361542
def callUDF(f: Function1[_, _], returnType: DataType, arg1: Column): Column = {
15371543
ScalaUdf(f, returnType, Seq(arg1.expr))
15381544
}
@@ -1543,7 +1549,9 @@ object functions {
15431549
*
15441550
* @group udf_funcs
15451551
* @since 1.3.0
1552+
* @deprecated As of 1.5.0, since it's redundant with udf()
15461553
*/
1554+
@deprecated("Use udf", "1.5.0")
15471555
def callUDF(f: Function2[_, _, _], returnType: DataType, arg1: Column, arg2: Column): Column = {
15481556
ScalaUdf(f, returnType, Seq(arg1.expr, arg2.expr))
15491557
}
@@ -1554,7 +1562,9 @@ object functions {
15541562
*
15551563
* @group udf_funcs
15561564
* @since 1.3.0
1565+
* @deprecated As of 1.5.0, since it's redundant with udf()
15571566
*/
1567+
@deprecated("Use udf", "1.5.0")
15581568
def callUDF(f: Function3[_, _, _, _], returnType: DataType, arg1: Column, arg2: Column, arg3: Column): Column = {
15591569
ScalaUdf(f, returnType, Seq(arg1.expr, arg2.expr, arg3.expr))
15601570
}
@@ -1565,7 +1575,9 @@ object functions {
15651575
*
15661576
* @group udf_funcs
15671577
* @since 1.3.0
1578+
* @deprecated As of 1.5.0, since it's redundant with udf()
15681579
*/
1580+
@deprecated("Use udf", "1.5.0")
15691581
def callUDF(f: Function4[_, _, _, _, _], returnType: DataType, arg1: Column, arg2: Column, arg3: Column, arg4: Column): Column = {
15701582
ScalaUdf(f, returnType, Seq(arg1.expr, arg2.expr, arg3.expr, arg4.expr))
15711583
}
@@ -1576,7 +1588,9 @@ object functions {
15761588
*
15771589
* @group udf_funcs
15781590
* @since 1.3.0
1591+
* @deprecated As of 1.5.0, since it's redundant with udf()
15791592
*/
1593+
@deprecated("Use udf", "1.5.0")
15801594
def callUDF(f: Function5[_, _, _, _, _, _], returnType: DataType, arg1: Column, arg2: Column, arg3: Column, arg4: Column, arg5: Column): Column = {
15811595
ScalaUdf(f, returnType, Seq(arg1.expr, arg2.expr, arg3.expr, arg4.expr, arg5.expr))
15821596
}
@@ -1587,7 +1601,9 @@ object functions {
15871601
*
15881602
* @group udf_funcs
15891603
* @since 1.3.0
1604+
* @deprecated As of 1.5.0, since it's redundant with udf()
15901605
*/
1606+
@deprecated("Use udf", "1.5.0")
15911607
def callUDF(f: Function6[_, _, _, _, _, _, _], returnType: DataType, arg1: Column, arg2: Column, arg3: Column, arg4: Column, arg5: Column, arg6: Column): Column = {
15921608
ScalaUdf(f, returnType, Seq(arg1.expr, arg2.expr, arg3.expr, arg4.expr, arg5.expr, arg6.expr))
15931609
}
@@ -1598,7 +1614,9 @@ object functions {
15981614
*
15991615
* @group udf_funcs
16001616
* @since 1.3.0
1617+
* @deprecated As of 1.5.0, since it's redundant with udf()
16011618
*/
1619+
@deprecated("Use udf", "1.5.0")
16021620
def callUDF(f: Function7[_, _, _, _, _, _, _, _], returnType: DataType, arg1: Column, arg2: Column, arg3: Column, arg4: Column, arg5: Column, arg6: Column, arg7: Column): Column = {
16031621
ScalaUdf(f, returnType, Seq(arg1.expr, arg2.expr, arg3.expr, arg4.expr, arg5.expr, arg6.expr, arg7.expr))
16041622
}
@@ -1609,7 +1627,9 @@ object functions {
16091627
*
16101628
* @group udf_funcs
16111629
* @since 1.3.0
1630+
* @deprecated As of 1.5.0, since it's redundant with udf()
16121631
*/
1632+
@deprecated("Use udf", "1.5.0")
16131633
def callUDF(f: Function8[_, _, _, _, _, _, _, _, _], returnType: DataType, arg1: Column, arg2: Column, arg3: Column, arg4: Column, arg5: Column, arg6: Column, arg7: Column, arg8: Column): Column = {
16141634
ScalaUdf(f, returnType, Seq(arg1.expr, arg2.expr, arg3.expr, arg4.expr, arg5.expr, arg6.expr, arg7.expr, arg8.expr))
16151635
}
@@ -1620,7 +1640,9 @@ object functions {
16201640
*
16211641
* @group udf_funcs
16221642
* @since 1.3.0
1643+
* @deprecated As of 1.5.0, since it's redundant with udf()
16231644
*/
1645+
@deprecated("Use udf", "1.5.0")
16241646
def callUDF(f: Function9[_, _, _, _, _, _, _, _, _, _], returnType: DataType, arg1: Column, arg2: Column, arg3: Column, arg4: Column, arg5: Column, arg6: Column, arg7: Column, arg8: Column, arg9: Column): Column = {
16251647
ScalaUdf(f, returnType, Seq(arg1.expr, arg2.expr, arg3.expr, arg4.expr, arg5.expr, arg6.expr, arg7.expr, arg8.expr, arg9.expr))
16261648
}
@@ -1631,7 +1653,9 @@ object functions {
16311653
*
16321654
* @group udf_funcs
16331655
* @since 1.3.0
1656+
* @deprecated As of 1.5.0, since it's redundant with udf()
16341657
*/
1658+
@deprecated("Use udf", "1.5.0")
16351659
def callUDF(f: Function10[_, _, _, _, _, _, _, _, _, _, _], returnType: DataType, arg1: Column, arg2: Column, arg3: Column, arg4: Column, arg5: Column, arg6: Column, arg7: Column, arg8: Column, arg9: Column, arg10: Column): Column = {
16361660
ScalaUdf(f, returnType, Seq(arg1.expr, arg2.expr, arg3.expr, arg4.expr, arg5.expr, arg6.expr, arg7.expr, arg8.expr, arg9.expr, arg10.expr))
16371661
}

0 commit comments

Comments
 (0)