Skip to content

Commit c500f29

Browse files
committed
renamed a few variables in functions to use UDF
1 parent 8ab0f2d commit c500f29

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -257,7 +257,7 @@ class SQLContext(@transient val sparkContext: SparkContext)
257257
*
258258
* The following example registers a Scala closure as UDF:
259259
* {{{
260-
* sqlContext.udf.register("myUdf", (arg1: Int, arg2: String) => arg2 + arg1)
260+
* sqlContext.udf.register("myUDF", (arg1: Int, arg2: String) => arg2 + arg1)
261261
* }}}
262262
*
263263
* The following example registers a UDF in Java:

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1477,7 +1477,7 @@ object functions {
14771477
(0 to 10).map { x =>
14781478
val args = (1 to x).map(i => s"arg$i: Column").mkString(", ")
14791479
val fTypes = Seq.fill(x + 1)("_").mkString(", ")
1480-
val argsInUdf = (1 to x).map(i => s"arg$i.expr").mkString(", ")
1480+
val argsInUDF = (1 to x).map(i => s"arg$i.expr").mkString(", ")
14811481
println(s"""
14821482
/**
14831483
* Call a Scala function of ${x} arguments as user-defined function (UDF). This requires
@@ -1489,7 +1489,7 @@ object functions {
14891489
*/
14901490
@deprecated("Use udf", "1.5.0")
14911491
def callUDF(f: Function$x[$fTypes], returnType: DataType${if (args.length > 0) ", " + args else ""}): Column = {
1492-
ScalaUdf(f, returnType, Seq($argsInUdf))
1492+
ScalaUDF(f, returnType, Seq($argsInUDF))
14931493
}""")
14941494
}
14951495
}
@@ -1770,8 +1770,8 @@ object functions {
17701770
*
17711771
* val df = Seq(("id1", 1), ("id2", 4), ("id3", 5)).toDF("id", "value")
17721772
* val sqlContext = df.sqlContext
1773-
* sqlContext.udf.register("simpleUdf", (v: Int) => v * v)
1774-
* df.select($"id", callUDF("simpleUdf", $"value"))
1773+
* sqlContext.udf.register("simpleUDF", (v: Int) => v * v)
1774+
* df.select($"id", callUDF("simpleUDF", $"value"))
17751775
* }}}
17761776
*
17771777
* @group udf_funcs
@@ -1789,8 +1789,8 @@ object functions {
17891789
*
17901790
* val df = Seq(("id1", 1), ("id2", 4), ("id3", 5)).toDF("id", "value")
17911791
* val sqlContext = df.sqlContext
1792-
* sqlContext.udf.register("simpleUdf", (v: Int) => v * v)
1793-
* df.select($"id", callUdf("simpleUdf", $"value"))
1792+
* sqlContext.udf.register("simpleUDF", (v: Int) => v * v)
1793+
* df.select($"id", callUdf("simpleUDF", $"value"))
17941794
* }}}
17951795
*
17961796
* @group udf_funcs

0 commit comments

Comments
 (0)