diff options
| author | Reynold Xin <rxin@databricks.com> | 2017-04-04 22:46:42 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2017-04-04 22:46:42 -0700 |
| commit | b6e71032d92a072b7c951e5ea641e9454b5e70ed (patch) | |
| tree | cab7f05173f4cfe2db28f3efdecbf23b51cce47b /sql/core/src/main | |
| parent | c1b8b667506ed95c6c2808e7d3db8463435e73f6 (diff) | |
| download | spark-b6e71032d92a072b7c951e5ea641e9454b5e70ed.tar.gz spark-b6e71032d92a072b7c951e5ea641e9454b5e70ed.tar.bz2 spark-b6e71032d92a072b7c951e5ea641e9454b5e70ed.zip | |
Small doc fix for ReuseSubquery.
Diffstat (limited to 'sql/core/src/main')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/subquery.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/subquery.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/subquery.scala index 58be2d1da2..d11045fb6a 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/subquery.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/subquery.scala @@ -150,7 +150,7 @@ case class PlanSubqueries(sparkSession: SparkSession) extends Rule[SparkPlan] { /** - * Find out duplicated exchanges in the spark plan, then use the same exchange for all the + * Find out duplicated subqueries in the spark plan, then use the same subquery result for all the * references. */ case class ReuseSubquery(conf: SQLConf) extends Rule[SparkPlan] { @@ -159,7 +159,7 @@ case class ReuseSubquery(conf: SQLConf) extends Rule[SparkPlan] { if (!conf.exchangeReuseEnabled) { return plan } - // Build a hash map using schema of exchanges to avoid O(N*N) sameResult calls. + // Build a hash map using schema of subqueries to avoid O(N*N) sameResult calls. val subqueries = mutable.HashMap[StructType, ArrayBuffer[SubqueryExec]]() plan transformAllExpressions { case sub: ExecSubqueryExpression => |