You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by hv...@apache.org on 2017/04/20 12:30:05 UTC
spark git commit: [SPARK-20405][SQL] Dataset.withNewExecutionId
should be private
Repository: spark
Updated Branches:
refs/heads/master 55bea5691 -> c6f62c5b8
[SPARK-20405][SQL] Dataset.withNewExecutionId should be private
## What changes were proposed in this pull request?
Dataset.withNewExecutionId is only used in Dataset itself and should be private.
## How was this patch tested?
N/A - this is a simple visibility change.
Author: Reynold Xin <rx...@databricks.com>
Closes #17699 from rxin/SPARK-20405.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/c6f62c5b
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/c6f62c5b
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/c6f62c5b
Branch: refs/heads/master
Commit: c6f62c5b8106534007df31ca8c460064b89b450b
Parents: 55bea56
Author: Reynold Xin <rx...@databricks.com>
Authored: Thu Apr 20 14:29:59 2017 +0200
Committer: Herman van Hovell <hv...@databricks.com>
Committed: Thu Apr 20 14:29:59 2017 +0200
----------------------------------------------------------------------
sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/c6f62c5b/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala b/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
index 520663f..c6dcd93 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
@@ -2778,7 +2778,7 @@ class Dataset[T] private[sql](
* Wrap a Dataset action to track all Spark jobs in the body so that we can connect them with
* an execution.
*/
- private[sql] def withNewExecutionId[U](body: => U): U = {
+ private def withNewExecutionId[U](body: => U): U = {
SQLExecution.withNewExecutionId(sparkSession, queryExecution)(body)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org