You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ch...@apache.org on 2017/05/01 09:55:17 UTC
[1/2] incubator-carbondata git commit: Range filter test fix
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 <ra...@gmail.com>
Authored: Mon May 1 08:23:15 2017 +0530
Committer: ravipesala <ra...@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")),
[2/2] incubator-carbondata git commit: [CARBONDATA-1006] Range filter
test fix This closes #871
Posted by ch...@apache.org.
[CARBONDATA-1006] Range filter test fix This closes #871
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/33bfb493
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/33bfb493
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/33bfb493
Branch: refs/heads/master
Commit: 33bfb493a92d9d07320d36c10edcadadb15525ca
Parents: b99c2c1 2b5d566
Author: chenliang613 <ch...@huawei.com>
Authored: Mon May 1 17:55:02 2017 +0800
Committer: chenliang613 <ch...@huawei.com>
Committed: Mon May 1 17:55:02 2017 +0800
----------------------------------------------------------------------
.../RangeFilterAllDataTypesTestCases.scala | 17 +++++++++++------
1 file changed, 11 insertions(+), 6 deletions(-)
----------------------------------------------------------------------