You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2015/05/18 21:02:03 UTC
spark git commit: [SQL] [MINOR] [THIS] use private for internal field
in ScalaUdf
Repository: spark
Updated Branches:
refs/heads/master 010a1c278 -> 56ede8848
[SQL] [MINOR] [THIS] use private for internal field in ScalaUdf
Author: Wenchen Fan <cl...@outlook.com>
Closes #6235 from cloud-fan/tmp and squashes the following commits:
8f16367 [Wenchen Fan] use private[this]
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/56ede884
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/56ede884
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/56ede884
Branch: refs/heads/master
Commit: 56ede88485cfca90974425fcb603b257be47229b
Parents: 010a1c2
Author: Wenchen Fan <cl...@outlook.com>
Authored: Mon May 18 12:01:30 2015 -0700
Committer: Michael Armbrust <mi...@databricks.com>
Committed: Mon May 18 12:01:30 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/56ede884/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: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org