carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject [1/2] incubator-carbondata git commit: Whenever a not equal to filter is applied on dictionary column with numeric datatype, the cast added by spark plan is removed while creating carbon filters from spark filter. Due to this plan modification incorrect
Date Thu, 23 Mar 2017 04:25:08 GMT
Repository: incubator-carbondata
Updated Branches:
  refs/heads/master c2a3e7d9b -> 9f38a3dde


Whenever a not equal to filter is applied on dictionary column with numeric datatype, the
cast added by spark plan is removed while creating carbon filters from spark filter. Due to
this plan modification incorrect results are returned by spark.


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

Branch: refs/heads/master
Commit: ae86464dfb34d9556ad62cf30ad3618dc6907961
Parents: c2a3e7d
Author: manishgupta88 <tomanishgupta18@gmail.com>
Authored: Tue Mar 21 23:15:43 2017 +0530
Committer: ravipesala <ravi.pesala@gmail.com>
Committed: Thu Mar 23 09:53:45 2017 +0530

----------------------------------------------------------------------
 .../test/resources/filter/notEqualToFilter.csv  |  3 +
 .../DateDataTypeDirectDictionaryTest.scala      | 15 +---
 ...TypeDirectDictionaryWithNoDictTestCase.scala |  2 +-
 .../apache/carbondata/spark/CarbonFilters.scala | 42 +++------
 .../execution/CarbonLateDecodeStrategy.scala    | 59 ++++---------
 .../carbondata/query/TestNotEqualToFilter.scala | 90 ++++++++++++++++++++
 6 files changed, 124 insertions(+), 87 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/ae86464d/integration/spark-common-test/src/test/resources/filter/notEqualToFilter.csv
----------------------------------------------------------------------
diff --git a/integration/spark-common-test/src/test/resources/filter/notEqualToFilter.csv
b/integration/spark-common-test/src/test/resources/filter/notEqualToFilter.csv
new file mode 100644
index 0000000..31ed808
--- /dev/null
+++ b/integration/spark-common-test/src/test/resources/filter/notEqualToFilter.csv
@@ -0,0 +1,3 @@
+1,2015-07-23 00:00:00,china,aaa1,phone197,ASD69643,15000
+7,2015-07-24 00:00:00,china,aaa2,phone756,ASD42892,15001
+7,2015-07-25 00:00:00,china,aaa3,phone1904,ASD37014,15002

http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/ae86464d/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/directdictionary/DateDataTypeDirectDictionaryTest.scala
----------------------------------------------------------------------
diff --git a/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/directdictionary/DateDataTypeDirectDictionaryTest.scala
b/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/directdictionary/DateDataTypeDirectDictionaryTest.scala
index 2e5eeb0..267bdf8 100644
--- a/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/directdictionary/DateDataTypeDirectDictionaryTest.scala
+++ b/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/directdictionary/DateDataTypeDirectDictionaryTest.scala
@@ -39,25 +39,17 @@ class DateDataTypeDirectDictionaryTest extends QueryTest with BeforeAndAfterAll
     try {
       CarbonProperties.getInstance().addProperty("carbon.direct.dictionary", "true")
       sql("drop table if exists directDictionaryTable ")
-      sql("drop table if exists directDictionaryTable_hive ")
       sql(
         "CREATE TABLE if not exists directDictionaryTable (empno int,doj date, " +
           "salary int) " +
           "STORED BY 'org.apache.carbondata.format'"
       )
 
-      sql(
-        "CREATE TABLE if not exists directDictionaryTable_hive (empno int,doj date, " +
-          "salary int) " +
-          "row format delimited fields terminated by ','"
-      )
-
       CarbonProperties.getInstance()
         .addProperty(CarbonCommonConstants.CARBON_DATE_FORMAT, "yyyy-MM-dd")
       val csvFilePath = s"$resourcesPath/datasamplefordate.csv"
       sql("LOAD DATA local inpath '" + csvFilePath + "' INTO TABLE directDictionaryTable
OPTIONS" +
         "('DELIMITER'= ',', 'QUOTECHAR'= '\"')" )
-      sql("LOAD DATA local inpath '" + csvFilePath + "' INTO TABLE directDictionaryTable_hive")
     } catch {
       case x: Throwable =>
         x.printStackTrace()
@@ -87,7 +79,7 @@ class DateDataTypeDirectDictionaryTest extends QueryTest with BeforeAndAfterAll
 
   test("test direct dictionary for not equals condition") {
     checkAnswer(
-      sql("select doj from directDictionaryTable where doj != '2016-04-14 00:00:00'"),
+      sql("select doj from directDictionaryTable where doj != '2016-04-14'"),
       Seq(Row(Date.valueOf("2016-03-14"))
       )
     )
@@ -103,7 +95,7 @@ class DateDataTypeDirectDictionaryTest extends QueryTest with BeforeAndAfterAll
 
   test("select doj from directDictionaryTable with equals filter") {
     checkAnswer(
-      sql("select doj from directDictionaryTable where doj = '2016-03-14 00:00:00'"),
+      sql("select doj from directDictionaryTable where doj = '2016-03-14'"),
       Seq(Row(Date.valueOf("2016-03-14")))
     )
 
@@ -119,7 +111,7 @@ class DateDataTypeDirectDictionaryTest extends QueryTest with BeforeAndAfterAll
   test("select doj from directDictionaryTable with regexp_replace NOT IN filter") {
     checkAnswer(
       sql("select doj from directDictionaryTable where regexp_replace(doj, '-', '/') NOT
IN ('2016/03/14')"),
-      sql("select doj from directDictionaryTable_hive where regexp_replace(doj, '-', '/')
NOT IN ('2016/03/14')")
+      Seq(Row(Date.valueOf("2016-04-14")))
     )
   }
 
@@ -139,7 +131,6 @@ class DateDataTypeDirectDictionaryTest extends QueryTest with BeforeAndAfterAll
 
   override def afterAll {
     sql("drop table directDictionaryTable")
-    sql("drop table directDictionaryTable_hive")
     CarbonProperties.getInstance()
       .addProperty(CarbonCommonConstants.CARBON_DATE_FORMAT, "dd-MM-yyyy")
     CarbonProperties.getInstance().addProperty("carbon.direct.dictionary", "false")

http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/ae86464d/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/directdictionary/DateDataTypeDirectDictionaryWithNoDictTestCase.scala
----------------------------------------------------------------------
diff --git a/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/directdictionary/DateDataTypeDirectDictionaryWithNoDictTestCase.scala
b/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/directdictionary/DateDataTypeDirectDictionaryWithNoDictTestCase.scala
index 2ad8592..e8d4a92 100644
--- a/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/directdictionary/DateDataTypeDirectDictionaryWithNoDictTestCase.scala
+++ b/integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/directdictionary/DateDataTypeDirectDictionaryWithNoDictTestCase.scala
@@ -72,7 +72,7 @@ class DateDataTypeDirectDictionaryWithNoDictTestCase extends QueryTest with
Befo
 
   test("select doj from directDictionaryTable with equals filter") {
     checkAnswer(
-      sql("select doj from directDictionaryTable where doj='2016-03-14 15:00:09'"),
+      sql("select doj from directDictionaryTable where doj='2016-03-14'"),
       Seq(Row(Date.valueOf("2016-03-14")))
     )
 

http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/ae86464d/integration/spark-common/src/main/scala/org/apache/carbondata/spark/CarbonFilters.scala
----------------------------------------------------------------------
diff --git a/integration/spark-common/src/main/scala/org/apache/carbondata/spark/CarbonFilters.scala
b/integration/spark-common/src/main/scala/org/apache/carbondata/spark/CarbonFilters.scala
index 3d13c6b..7a3c737 100644
--- a/integration/spark-common/src/main/scala/org/apache/carbondata/spark/CarbonFilters.scala
+++ b/integration/spark-common/src/main/scala/org/apache/carbondata/spark/CarbonFilters.scala
@@ -141,24 +141,26 @@ object CarbonFilters {
           }
 
         case And(left, right) =>
-          (translate(left) ++ translate(right)).reduceOption(sources.And)
+          val leftFilter = translate(left, or)
+          val rightFilter = translate(right, or)
+          if (or) {
+            if (leftFilter.isDefined && rightFilter.isDefined) {
+              (leftFilter ++ rightFilter).reduceOption(sources.And)
+            } else {
+              None
+            }
+          } else {
+            (leftFilter ++ rightFilter).reduceOption(sources.And)
+          }
 
         case EqualTo(a: Attribute, Literal(v, t)) =>
           Some(sources.EqualTo(a.name, v))
         case EqualTo(l@Literal(v, t), a: Attribute) =>
           Some(sources.EqualTo(a.name, v))
-        case EqualTo(Cast(a: Attribute, _), Literal(v, t)) =>
-          Some(sources.EqualTo(a.name, v))
-        case EqualTo(Literal(v, t), Cast(a: Attribute, _)) =>
-          Some(sources.EqualTo(a.name, v))
         case Not(EqualTo(a: Attribute, Literal(v, t))) =>
           Some(sources.Not(sources.EqualTo(a.name, v)))
         case Not(EqualTo(Literal(v, t), a: Attribute)) =>
           Some(sources.Not(sources.EqualTo(a.name, v)))
-        case Not(EqualTo(Cast(a: Attribute, _), Literal(v, t))) =>
-          Some(sources.Not(sources.EqualTo(a.name, v)))
-        case Not(EqualTo(Literal(v, t), Cast(a: Attribute, _))) =>
-          Some(sources.Not(sources.EqualTo(a.name, v)))
         case IsNotNull(a: Attribute) =>
           Some(sources.IsNotNull(a.name))
         case IsNull(a: Attribute) =>
@@ -169,44 +171,22 @@ object CarbonFilters {
         case In(a: Attribute, list) if !list.exists(!_.isInstanceOf[Literal]) =>
           val hSet = list.map(e => e.eval(EmptyRow))
           Some(sources.In(a.name, hSet.toArray))
-        case Not(In(Cast(a: Attribute, _), list)) if !list.exists(!_.isInstanceOf[Literal])
=>
-          val hSet = list.map(e => e.eval(EmptyRow))
-          Some(sources.Not(sources.In(a.name, hSet.toArray)))
-        case In(Cast(a: Attribute, _), list) if !list.exists(!_.isInstanceOf[Literal]) =>
-          val hSet = list.map(e => e.eval(EmptyRow))
-          Some(sources.In(a.name, hSet.toArray))
         case GreaterThan(a: Attribute, Literal(v, t)) =>
           Some(sources.GreaterThan(a.name, v))
         case GreaterThan(Literal(v, t), a: Attribute) =>
           Some(sources.LessThan(a.name, v))
-        case GreaterThan(Cast(a: Attribute, _), Literal(v, t)) =>
-          Some(sources.GreaterThan(a.name, v))
-        case GreaterThan(Literal(v, t), Cast(a: Attribute, _)) =>
-          Some(sources.LessThan(a.name, v))
         case LessThan(a: Attribute, Literal(v, t)) =>
           Some(sources.LessThan(a.name, v))
         case LessThan(Literal(v, t), a: Attribute) =>
           Some(sources.GreaterThan(a.name, v))
-        case LessThan(Cast(a: Attribute, _), Literal(v, t)) =>
-          Some(sources.LessThan(a.name, v))
-        case LessThan(Literal(v, t), Cast(a: Attribute, _)) =>
-          Some(sources.GreaterThan(a.name, v))
         case GreaterThanOrEqual(a: Attribute, Literal(v, t)) =>
           Some(sources.GreaterThanOrEqual(a.name, v))
         case GreaterThanOrEqual(Literal(v, t), a: Attribute) =>
           Some(sources.LessThanOrEqual(a.name, v))
-        case GreaterThanOrEqual(Cast(a: Attribute, _), Literal(v, t)) =>
-          Some(sources.GreaterThanOrEqual(a.name, v))
-        case GreaterThanOrEqual(Literal(v, t), Cast(a: Attribute, _)) =>
-          Some(sources.LessThanOrEqual(a.name, v))
         case LessThanOrEqual(a: Attribute, Literal(v, t)) =>
           Some(sources.LessThanOrEqual(a.name, v))
         case LessThanOrEqual(Literal(v, t), a: Attribute) =>
           Some(sources.GreaterThanOrEqual(a.name, v))
-        case LessThanOrEqual(Cast(a: Attribute, _), Literal(v, t)) =>
-          Some(sources.LessThanOrEqual(a.name, v))
-        case LessThanOrEqual(Literal(v, t), Cast(a: Attribute, _)) =>
-          Some(sources.GreaterThanOrEqual(a.name, v))
 
         case others =>
           if (!or) {

http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/ae86464d/integration/spark2/src/main/scala/org/apache/spark/sql/execution/CarbonLateDecodeStrategy.scala
----------------------------------------------------------------------
diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/CarbonLateDecodeStrategy.scala
b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/CarbonLateDecodeStrategy.scala
index 549cc1e..16e8a99 100644
--- a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/CarbonLateDecodeStrategy.scala
+++ b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/CarbonLateDecodeStrategy.scala
@@ -393,38 +393,39 @@ private[sql] class CarbonLateDecodeStrategy extends SparkStrategy {
    * Tries to translate a Catalyst [[Expression]] into data source [[Filter]].
    * @return a `Some[Filter]` if the input [[Expression]] is convertible, otherwise a `None`.
    */
-  protected[sql] def translateFilter(predicate: Expression): Option[Filter] = {
+  protected[sql] def translateFilter(predicate: Expression, or: Boolean = false): Option[Filter]
= {
     predicate match {
-      case or@ Or(left, right) =>
+      case or@Or(left, right) =>
 
-        val leftFilter = translateFilter(left)
-        val rightFilter = translateFilter(right)
+        val leftFilter = translateFilter(left, true)
+        val rightFilter = translateFilter(right, true)
         if (leftFilter.isDefined && rightFilter.isDefined) {
-          Some( sources.Or(leftFilter.get, rightFilter.get))
+          Some(sources.Or(leftFilter.get, rightFilter.get))
         } else {
           None
         }
 
       case And(left, right) =>
-        (translateFilter(left) ++ translateFilter(right)).reduceOption(sources.And)
+        val leftFilter = translateFilter(left, or)
+        val rightFilter = translateFilter(right, or)
+        if (or) {
+          if (leftFilter.isDefined && rightFilter.isDefined) {
+            (translateFilter(left) ++ translateFilter(right)).reduceOption(sources.And)
+          } else {
+            None
+          }
+        } else {
+          (translateFilter(left) ++ translateFilter(right)).reduceOption(sources.And)
+        }
 
       case EqualTo(a: Attribute, Literal(v, t)) =>
         Some(sources.EqualTo(a.name, v))
       case EqualTo(l@Literal(v, t), a: Attribute) =>
         Some(sources.EqualTo(a.name, v))
-      case EqualTo(Cast(a: Attribute, _), Literal(v, t)) =>
-        Some(sources.EqualTo(a.name, v))
-      case EqualTo(Literal(v, t), Cast(a: Attribute, _)) =>
-        Some(sources.EqualTo(a.name, v))
-
       case Not(EqualTo(a: Attribute, Literal(v, t))) =>
           Some(sources.Not(sources.EqualTo(a.name, v)))
       case Not(EqualTo(Literal(v, t), a: Attribute)) =>
           Some(sources.Not(sources.EqualTo(a.name, v)))
-      case Not(EqualTo(Cast(a: Attribute, _), Literal(v, t))) =>
-          Some(sources.Not(sources.EqualTo(a.name, v)))
-      case Not(EqualTo(Literal(v, t), Cast(a: Attribute, _))) =>
-          Some(sources.Not(sources.EqualTo(a.name, v)))
       case IsNotNull(a: Attribute) => Some(sources.IsNotNull(a.name))
       case IsNull(a: Attribute) => Some(sources.IsNull(a.name))
       case Not(In(a: Attribute, list)) if !list.exists(!_.isInstanceOf[Literal]) =>
@@ -433,50 +434,22 @@ private[sql] class CarbonLateDecodeStrategy extends SparkStrategy {
       case In(a: Attribute, list) if !list.exists(!_.isInstanceOf[Literal]) =>
         val hSet = list.map(e => e.eval(EmptyRow))
         Some(sources.In(a.name, hSet.toArray))
-      case Not(In(Cast(a: Attribute, _), list))
-        if !list.exists(!_.isInstanceOf[Literal]) =>
-        val hSet = list.map(e => e.eval(EmptyRow))
-        Some(sources.Not(sources.In(a.name, hSet.toArray)))
-      case In(Cast(a: Attribute, _), list) if !list.exists(!_.isInstanceOf[Literal]) =>
-        val hSet = list.map(e => e.eval(EmptyRow))
-        Some(sources.In(a.name, hSet.toArray))
-
       case GreaterThan(a: Attribute, Literal(v, t)) =>
         Some(sources.GreaterThan(a.name, v))
       case GreaterThan(Literal(v, t), a: Attribute) =>
         Some(sources.LessThan(a.name, v))
-      case GreaterThan(Cast(a: Attribute, _), Literal(v, t)) =>
-        Some(sources.GreaterThan(a.name, v))
-      case GreaterThan(Literal(v, t), Cast(a: Attribute, _)) =>
-        Some(sources.LessThan(a.name, v))
-
       case LessThan(a: Attribute, Literal(v, t)) =>
         Some(sources.LessThan(a.name, v))
       case LessThan(Literal(v, t), a: Attribute) =>
         Some(sources.GreaterThan(a.name, v))
-      case LessThan(Cast(a: Attribute, _), Literal(v, t)) =>
-        Some(sources.LessThan(a.name, v))
-      case LessThan(Literal(v, t), Cast(a: Attribute, _)) =>
-        Some(sources.GreaterThan(a.name, v))
-
       case GreaterThanOrEqual(a: Attribute, Literal(v, t)) =>
         Some(sources.GreaterThanOrEqual(a.name, v))
       case GreaterThanOrEqual(Literal(v, t), a: Attribute) =>
         Some(sources.LessThanOrEqual(a.name, v))
-      case GreaterThanOrEqual(Cast(a: Attribute, _), Literal(v, t)) =>
-        Some(sources.GreaterThanOrEqual(a.name, v))
-      case GreaterThanOrEqual(Literal(v, t), Cast(a: Attribute, _)) =>
-        Some(sources.LessThanOrEqual(a.name, v))
-
       case LessThanOrEqual(a: Attribute, Literal(v, t)) =>
         Some(sources.LessThanOrEqual(a.name, v))
       case LessThanOrEqual(Literal(v, t), a: Attribute) =>
         Some(sources.GreaterThanOrEqual(a.name, v))
-      case LessThanOrEqual(Cast(a: Attribute, _), Literal(v, t)) =>
-        Some(sources.LessThanOrEqual(a.name, v))
-      case LessThanOrEqual(Literal(v, t), Cast(a: Attribute, _)) =>
-        Some(sources.GreaterThanOrEqual(a.name, v))
-
       case others => None
     }
   }

http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/ae86464d/integration/spark2/src/test/scala/org/apache/spark/carbondata/query/TestNotEqualToFilter.scala
----------------------------------------------------------------------
diff --git a/integration/spark2/src/test/scala/org/apache/spark/carbondata/query/TestNotEqualToFilter.scala
b/integration/spark2/src/test/scala/org/apache/spark/carbondata/query/TestNotEqualToFilter.scala
new file mode 100644
index 0000000..fb0188c
--- /dev/null
+++ b/integration/spark2/src/test/scala/org/apache/spark/carbondata/query/TestNotEqualToFilter.scala
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.spark.carbondata.query
+
+import org.apache.spark.sql.common.util.QueryTest
+import org.scalatest.BeforeAndAfterAll
+
+import org.apache.carbondata.core.constants.CarbonCommonConstants
+import org.apache.carbondata.core.util.CarbonProperties
+
+/**
+ * Test cases for testing columns having \N or \null values for non numeric columns
+ */
+class TestNotEqualToFilter extends QueryTest with BeforeAndAfterAll {
+
+  override def beforeAll {
+    sql("drop table if exists test_not_equal_to_carbon")
+    sql("drop table if exists test_not_equal_to_hive")
+    CarbonProperties.getInstance()
+      .addProperty(CarbonCommonConstants.CARBON_TIMESTAMP_FORMAT,
+        CarbonCommonConstants.CARBON_TIMESTAMP_DEFAULT_FORMAT
+      )
+    sql(
+      """
+        CREATE TABLE IF NOT EXISTS test_not_equal_to_carbon
+        (ID Int, date Timestamp, country String,
+        name String, phonetype String, serialname String, salary Int)
+        STORED BY 'org.apache.carbondata.format' TBLPROPERTIES('dictionary_include'='id')
+      """)
+    sql(
+      """
+        CREATE TABLE IF NOT EXISTS test_not_equal_to_hive
+        (ID Int, date Timestamp, country String,
+        name String, phonetype String, serialname String, salary Int)
+        row format delimited fields terminated by ','
+      """)
+    sql(
+      s"""
+           LOAD DATA LOCAL INPATH '$resourcesPath/filter/notEqualToFilter.csv' into table
+           test_not_equal_to_carbon
+           OPTIONS('FILEHEADER'='ID,date,country,name,phonetype,serialname,salary')
+           """)
+    sql(
+      s"""
+           LOAD DATA LOCAL INPATH '$resourcesPath/filter/notEqualToFilter.csv' into table
+           test_not_equal_to_hive
+           """)
+  }
+
+  test("select Id from test_not_equal_to_carbon where id != '7'") {
+    checkAnswer(
+      sql("select Id from test_not_equal_to_carbon where id != '7'"),
+      sql("select Id from test_not_equal_to_hive where id != '7'")
+    )
+  }
+
+  test("select Id from test_not_equal_to_carbon where id != 7.0") {
+    checkAnswer(
+      sql("select Id from test_not_equal_to_carbon where id != 7.0"),
+      sql("select Id from test_not_equal_to_hive where id != 7.0")
+    )
+  }
+
+  test("select Id from test_not_equal_to_carbon where id != 7") {
+    checkAnswer(
+      sql("select Id from test_not_equal_to_carbon where id != 7"),
+      sql("select Id from test_not_equal_to_hive where id != 7")
+    )
+  }
+
+  override def afterAll {
+    sql("drop table if exists test_not_equal_to_carbon")
+    sql("drop table if exists test_not_equal_to_hive")
+  }
+}


Mime
View raw message