diff options
author | Reynold Xin <rxin@apache.org> | 2014-06-19 18:24:05 -0700 |
---|---|---|
committer | Reynold Xin <rxin@apache.org> | 2014-06-19 18:24:05 -0700 |
commit | 5464e79175e2fc85e2cadf0dd7c9a45dad028326 (patch) | |
tree | 0a2e35eb679fe33c5e21af0853158de5a74ffc68 /sql/core/src/main | |
parent | f14b00a9c60863afda15681fbf5682247351fa39 (diff) | |
download | spark-5464e79175e2fc85e2cadf0dd7c9a45dad028326.tar.gz spark-5464e79175e2fc85e2cadf0dd7c9a45dad028326.tar.bz2 spark-5464e79175e2fc85e2cadf0dd7c9a45dad028326.zip |
A few minor Spark SQL Scaladoc fixes.
Author: Reynold Xin <rxin@apache.org>
Closes #1139 from rxin/sparksqldoc and squashes the following commits:
c3049d8 [Reynold Xin] Fixed line length.
66dc72c [Reynold Xin] A few minor Spark SQL Scaladoc fixes.
Diffstat (limited to 'sql/core/src/main')
-rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala index 05dfb85b38..f46fa05165 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala @@ -20,7 +20,7 @@ package org.apache.spark.sql.execution import org.apache.spark.annotation.DeveloperApi import org.apache.spark.{HashPartitioner, RangePartitioner, SparkConf} import org.apache.spark.rdd.ShuffledRDD -import org.apache.spark.sql.{SQLConf, SQLContext, Row} +import org.apache.spark.sql.{SQLContext, Row} import org.apache.spark.sql.catalyst.errors.attachTree import org.apache.spark.sql.catalyst.expressions.{NoBind, MutableProjection, RowOrdering} import org.apache.spark.sql.catalyst.plans.physical._ @@ -82,9 +82,10 @@ case class Exchange(newPartitioning: Partitioning, child: SparkPlan) extends Una } /** - * Ensures that the [[catalyst.plans.physical.Partitioning Partitioning]] of input data meets the - * [[catalyst.plans.physical.Distribution Distribution]] requirements for each operator by inserting - * [[Exchange]] Operators where required. + * Ensures that the [[org.apache.spark.sql.catalyst.plans.physical.Partitioning Partitioning]] + * of input data meets the + * [[org.apache.spark.sql.catalyst.plans.physical.Distribution Distribution]] requirements for + * each operator by inserting [[Exchange]] Operators where required. */ private[sql] case class AddExchange(sqlContext: SQLContext) extends Rule[SparkPlan] { // TODO: Determine the number of partitions. |