You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2015/04/03 02:23:58 UTC
spark git commit: [SPARK-6243][SQL] The Operation of match did not
conside the scenarios that order.dataType does not match NativeType
Repository: spark
Updated Branches:
refs/heads/master dfd2982bc -> 947802cb0
[SPARK-6243][SQL] The Operation of match did not conside the scenarios that order.dataType does not match NativeType
It did not conside that order.dataType does not match NativeType. So i add "case other => ..." for other cenarios.
Author: DoingDone9 <79...@qq.com>
Closes #4959 from DoingDone9/case_ and squashes the following commits:
6278846 [DoingDone9] Update rows.scala
cb1852d [DoingDone9] Merge pull request #2 from apache/master
c3f046f [DoingDone9] Merge pull request #1 from apache/master
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/947802cb
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/947802cb
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/947802cb
Branch: refs/heads/master
Commit: 947802cb0de581e51f8141f6663e896de3d753ce
Parents: dfd2982
Author: DoingDone9 <79...@qq.com>
Authored: Thu Apr 2 17:23:51 2015 -0700
Committer: Michael Armbrust <mi...@databricks.com>
Committed: Thu Apr 2 17:23:51 2015 -0700
----------------------------------------------------------------------
.../main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/947802cb/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala
----------------------------------------------------------------------
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala
index a8983df..0a275b8 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala
@@ -224,6 +224,7 @@ class RowOrdering(ordering: Seq[SortOrder]) extends Ordering[Row] {
n.ordering.asInstanceOf[Ordering[Any]].compare(left, right)
case n: NativeType if order.direction == Descending =>
n.ordering.asInstanceOf[Ordering[Any]].reverse.compare(left, right)
+ case other => sys.error(s"Type $other does not support ordered operations")
}
if (comparison != 0) return comparison
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org