diff options
| author | Daoyuan Wang <daoyuan.wang@intel.com> | 2015-07-06 15:54:43 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@databricks.com> | 2015-07-06 15:54:43 -0700 |
| commit | 132e7fca129be8f00ba429a51bcef60abb2eed6d (patch) | |
| tree | 05ac1edc0dbce872bf70d1cd6c1eb9b0d2e8b9f7 | |
| parent | 2471c0bf7f463bb144b44a2e51c0f363e71e099d (diff) | |
| download | spark-132e7fca129be8f00ba429a51bcef60abb2eed6d.tar.gz spark-132e7fca129be8f00ba429a51bcef60abb2eed6d.tar.bz2 spark-132e7fca129be8f00ba429a51bcef60abb2eed6d.zip | |
[MINOR] [SQL] remove unused code in Exchange
Author: Daoyuan Wang <daoyuan.wang@intel.com>
Closes #7234 from adrian-wang/exchangeclean and squashes the following commits:
b093ec9 [Daoyuan Wang] remove unused code
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala | 14 |
1 files changed, 0 insertions, 14 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 edc64a0333..e054c1d144 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 @@ -117,20 +117,6 @@ case class Exchange( } } - private val keyOrdering = { - if (newOrdering.nonEmpty) { - val key = newPartitioning.keyExpressions - val boundOrdering = newOrdering.map { o => - val ordinal = key.indexOf(o.child) - if (ordinal == -1) sys.error(s"Invalid ordering on $o requested for $newPartitioning") - o.copy(child = BoundReference(ordinal, o.child.dataType, o.child.nullable)) - } - new RowOrdering(boundOrdering) - } else { - null // Ordering will not be used - } - } - @transient private lazy val sparkConf = child.sqlContext.sparkContext.getConf private def getSerializer( |