aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorWenchen Fan <cloud0fan@outlook.com>2015-05-18 12:01:30 -0700
committerMichael Armbrust <michael@databricks.com>2015-05-18 12:01:30 -0700
commit56ede88485cfca90974425fcb603b257be47229b (patch)
tree417a8fa406b37524bd7c20fdeb70c644b2c75239
parent010a1c278037130a69dcc79427d2b0380a2c82d8 (diff)
downloadspark-56ede88485cfca90974425fcb603b257be47229b.tar.gz
spark-56ede88485cfca90974425fcb603b257be47229b.tar.bz2
spark-56ede88485cfca90974425fcb603b257be47229b.zip
[SQL] [MINOR] [THIS] use private for internal field in ScalaUdf
Author: Wenchen Fan <cloud0fan@outlook.com> Closes #6235 from cloud-fan/tmp and squashes the following commits: 8f16367 [Wenchen Fan] use private[this]
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUdf.scala8
1 files changed, 4 insertions, 4 deletions
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
index d22eb10ad3..fe2873e0be 100644
--- 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
@@ -55,9 +55,9 @@ case class ScalaUdf(function: AnyRef, dataType: DataType, children: Seq[Expressi
}.foreach(println)
*/
-
- val f = children.size match {
- case 0 =>
+
+ private[this] val f = children.size match {
+ case 0 =>
val func = function.asInstanceOf[() => Any]
(input: Row) => {
func()
@@ -956,7 +956,7 @@ case class ScalaUdf(function: AnyRef, dataType: DataType, children: Seq[Expressi
}
// scalastyle:on
- val converter = CatalystTypeConverters.createToCatalystConverter(dataType)
+ private[this] val converter = CatalystTypeConverters.createToCatalystConverter(dataType)
override def eval(input: Row): Any = converter(f(input))
}