Skip to content

Commit

Permalink
[MINOR] [SQL] remove unused code in Exchange
Browse files Browse the repository at this point in the history
Author: Daoyuan Wang <daoyuan.wang@intel.com>

Closes #7234 from adrian-wang/exchangeclean and squashes the following commits:

b093ec9 [Daoyuan Wang] remove unused code
  • Loading branch information
adrian-wang authored and JoshRosen committed Jul 6, 2015
1 parent 2471c0b commit 132e7fc
Showing 1 changed file with 0 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit 132e7fc

Please sign in to comment.