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:02:10 -0700
commit7d44c01c5ea87dda50f29bf715aee3e19e745b08 (patch)
tree4aa8ab77eca96a2f7570ff6d78cb24959a240e97
parentc7623a20a9a768fb0efad9db5d2a3a391ee67309 (diff)
downloadspark-7d44c01c5ea87dda50f29bf715aee3e19e745b08.tar.gz
spark-7d44c01c5ea87dda50f29bf715aee3e19e745b08.tar.bz2
spark-7d44c01c5ea87dda50f29bf715aee3e19e745b08.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] (cherry picked from commit 56ede88485cfca90974425fcb603b257be47229b) Signed-off-by: Michael Armbrust <michael@databricks.com>
-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))
}