This is an automated email from the ASF dual-hosted git repository.

hui pushed a commit to branch lmh/removeWithoutNull
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit ef3c013838cc5ab6e29a02476360c180a4ff78ef
Author: Minghui Liu <liuminghui...@foxmail.com>
AuthorDate: Tue Jul 12 15:54:51 2022 +0800

    throw exception while using without null clause in MPP
---
 .../apache/iotdb/db/mpp/plan/parser/ASTVisitor.java | 21 +--------------------
 1 file changed, 1 insertion(+), 20 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/ASTVisitor.java 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/ASTVisitor.java
index f04d2516f7..f758a24114 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/ASTVisitor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/ASTVisitor.java
@@ -61,8 +61,6 @@ import 
org.apache.iotdb.db.mpp.plan.expression.unary.RegularExpression;
 import org.apache.iotdb.db.mpp.plan.statement.Statement;
 import org.apache.iotdb.db.mpp.plan.statement.component.FillComponent;
 import org.apache.iotdb.db.mpp.plan.statement.component.FillPolicy;
-import org.apache.iotdb.db.mpp.plan.statement.component.FilterNullComponent;
-import org.apache.iotdb.db.mpp.plan.statement.component.FilterNullPolicy;
 import org.apache.iotdb.db.mpp.plan.statement.component.FromComponent;
 import org.apache.iotdb.db.mpp.plan.statement.component.GroupByLevelComponent;
 import org.apache.iotdb.db.mpp.plan.statement.component.GroupByTimeComponent;
@@ -1174,24 +1172,7 @@ public class ASTVisitor extends 
IoTDBSqlParserBaseVisitor<Statement> {
 
   // parse WITHOUT NULL
   private void parseWithoutNullClause(IoTDBSqlParser.WithoutNullClauseContext 
ctx) {
-    FilterNullComponent filterNullComponent = new FilterNullComponent();
-
-    // add without null columns
-    List<IoTDBSqlParser.ExpressionContext> expressionContexts = 
ctx.expression();
-    for (IoTDBSqlParser.ExpressionContext expressionContext : 
expressionContexts) {
-      
filterNullComponent.addWithoutNullColumn(parseExpression(expressionContext, 
true));
-    }
-
-    // set without null policy
-    if (ctx.ANY() != null) {
-      filterNullComponent.setWithoutPolicyType(FilterNullPolicy.CONTAINS_NULL);
-    } else if (ctx.ALL() != null) {
-      filterNullComponent.setWithoutPolicyType(FilterNullPolicy.ALL_NULL);
-    } else {
-      filterNullComponent.setWithoutPolicyType(FilterNullPolicy.NO_FILTER);
-    }
-
-    queryStatement.setFilterNullComponent(filterNullComponent);
+    throw new SemanticException("WITHOUT NULL clause is not supported yet.");
   }
 
   // ORDER BY TIME Clause

Reply via email to