diff options
author | Wenchen Fan <cloud0fan@outlook.com> | 2015-05-18 12:01:30 -0700 |
---|---|---|
committer | Michael Armbrust <michael@databricks.com> | 2015-05-18 12:02:10 -0700 |
commit | 7d44c01c5ea87dda50f29bf715aee3e19e745b08 (patch) | |
tree | 4aa8ab77eca96a2f7570ff6d78cb24959a240e97 | |
parent | c7623a20a9a768fb0efad9db5d2a3a391ee67309 (diff) | |
download | spark-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.scala | 8 |
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)) } |