Repository: spark Updated Branches: refs/heads/branch-1.4 c7623a20a -> 7d44c01c5
[SQL] [MINOR] [THIS] use private for internal field in ScalaUdf Author: Wenchen Fan <[email protected]> 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 <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/7d44c01c Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/7d44c01c Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/7d44c01c Branch: refs/heads/branch-1.4 Commit: 7d44c01c5ea87dda50f29bf715aee3e19e745b08 Parents: c7623a2 Author: Wenchen Fan <[email protected]> Authored: Mon May 18 12:01:30 2015 -0700 Committer: Michael Armbrust <[email protected]> Committed: Mon May 18 12:02:10 2015 -0700 ---------------------------------------------------------------------- .../org/apache/spark/sql/catalyst/expressions/ScalaUdf.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/7d44c01c/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUdf.scala ---------------------------------------------------------------------- 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 d22eb10..fe2873e 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)) } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
