carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chenliang...@apache.org
Subject [1/2] incubator-carbondata git commit: Range filter test fix
Date Mon, 01 May 2017 09:55:17 GMT
Repository: incubator-carbondata
Updated Branches:
  refs/heads/master b99c2c1a1 -> 33bfb493a


Range filter test fix


Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/2b5d566c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/2b5d566c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/2b5d566c

Branch: refs/heads/master
Commit: 2b5d566c604932c9b094befecf50d851f9ed955f
Parents: b99c2c1
Author: ravipesala <ravi.pesala@gmail.com>
Authored: Mon May 1 08:23:15 2017 +0530
Committer: ravipesala <ravi.pesala@gmail.com>
Committed: Mon May 1 08:23:15 2017 +0530

----------------------------------------------------------------------
 .../RangeFilterAllDataTypesTestCases.scala         | 17 +++++++++++------
 1 file changed, 11 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/2b5d566c/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/detailquery/RangeFilterAllDataTypesTestCases.scala
----------------------------------------------------------------------
diff --git a/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/detailquery/RangeFilterAllDataTypesTestCases.scala
b/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/detailquery/RangeFilterAllDataTypesTestCases.scala
index 3f42d56..e293d72 100644
--- a/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/detailquery/RangeFilterAllDataTypesTestCases.scala
+++ b/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/detailquery/RangeFilterAllDataTypesTestCases.scala
@@ -242,7 +242,6 @@ class RangeFilterMyTests extends QueryTest with BeforeAndAfterAll {
   }
 
   test("test range filter for direct dictionary"){
-    sql("select doj from directDictionaryTable where doj > cast('2016-03-14 15:00:17'
as timestamp)").show(2000,false)
     checkAnswer(
       sql("select doj from directDictionaryTable where doj > '2016-03-14 15:00:17'"),
       sql("select doj from directDictionaryTable_hive where doj > '2016-03-14 15:00:17'")
@@ -266,7 +265,6 @@ class RangeFilterMyTests extends QueryTest with BeforeAndAfterAll {
   }
 
   test("test range filter for direct dictionary not equality"){
-    sql("select doj from directDictionaryTable where doj != '2016-03-14 15:00:16'").show(2000,
false)
     checkAnswer(
       sql("select doj from directDictionaryTable where doj != '2016-03-14 15:00:16'"),
       Seq(Row(Timestamp.valueOf("2016-03-14 15:00:09.0")),
@@ -277,12 +275,21 @@ class RangeFilterMyTests extends QueryTest with BeforeAndAfterAll {
         Row(Timestamp.valueOf("2016-03-14 15:00:14.0")),
         Row(Timestamp.valueOf("2016-03-14 15:00:15.0")),
         Row(Timestamp.valueOf("2016-03-14 15:00:17.0")),
-        Row(Timestamp.valueOf("2016-03-14 15:00:18.0")))
+        Row(Timestamp.valueOf("2016-03-14 15:00:18.0")),
+        Row(Timestamp.valueOf("2016-03-14 15:00:19.0")),
+        Row(Timestamp.valueOf("2016-03-14 15:00:20.0")),
+        Row(Timestamp.valueOf("2016-03-14 15:00:24.0")),
+        Row(Timestamp.valueOf("2016-03-14 15:00:25.0")),
+        Row(Timestamp.valueOf("2016-03-14 15:00:31.0")),
+        Row(Timestamp.valueOf("2016-03-14 15:00:35.0")),
+        Row(Timestamp.valueOf("2016-03-14 15:00:38.0")),
+        Row(Timestamp.valueOf("2016-03-14 15:00:39.0")),
+        Row(Timestamp.valueOf("2016-03-14 15:00:49.0")),
+        Row(Timestamp.valueOf("2016-03-14 15:00:50.0")))
     )
   }
 
   test("test range filter for direct dictionary and with explicit casts"){
-    sql("select doj from directDictionaryTable where doj > cast ('2016-03-14 15:00:16'
as timestamp) and doj < cast ('2016-03-14 15:00:18' as timestamp)").show(2000, false)
     checkAnswer(
       sql("select doj from directDictionaryTable where doj > cast ('2016-03-14 15:00:16'
as timestamp) and doj < cast ('2016-03-14 15:00:18' as timestamp)"),
       Seq(Row(Timestamp.valueOf("2016-03-14 15:00:17.0"))
@@ -336,8 +343,6 @@ class RangeFilterMyTests extends QueryTest with BeforeAndAfterAll {
   }
 
   test("test range filter for different Timestamp In format "){
-    sql("select doj from directDictionaryTable").show(200,false)
-    sql("select * from directDictionaryTable where doj in ('2016-03-14 15:00:18', '2016-03-14
15:00:17' )").show(200, false)
     checkAnswer(
       sql("select doj from directDictionaryTable where doj in ('2016-03-14 15:00:18', '2016-03-14
15:00:17')"),
       Seq(Row(Timestamp.valueOf("2016-03-14 15:00:17.0")),


Mime
View raw message