This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-table-model-2 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 82866b9fbfb56912a23bd091f2004c856d7bee80 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Sep 25 11:16:23 2024 +0800 PipeStatement --- .../plan/relational/sql/ast/AlterPipe.java | 11 +-------- .../plan/relational/sql/ast/CreatePipe.java | 11 +-------- .../plan/relational/sql/ast/CreatePipePlugin.java | 11 +-------- .../plan/relational/sql/ast/DropPipe.java | 11 +-------- .../plan/relational/sql/ast/DropPipePlugin.java | 11 +-------- .../{ShowPipePlugins.java => PipeStatement.java} | 26 ++-------------------- .../plan/relational/sql/ast/ShowPipePlugins.java | 15 +------------ .../plan/relational/sql/ast/ShowPipes.java | 11 +-------- .../plan/relational/sql/ast/StartPipe.java | 11 +-------- .../plan/relational/sql/ast/StopPipe.java | 11 +-------- 10 files changed, 11 insertions(+), 118 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AlterPipe.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AlterPipe.java index ce2586ce878..4d398b55fcc 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AlterPipe.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AlterPipe.java @@ -19,16 +19,13 @@ package org.apache.iotdb.db.queryengine.plan.relational.sql.ast; -import com.google.common.collect.ImmutableList; - -import java.util.List; import java.util.Map; import java.util.Objects; import static com.google.common.base.MoreObjects.toStringHelper; import static java.util.Objects.requireNonNull; -public class AlterPipe extends Statement { +public class AlterPipe extends PipeStatement { private final String pipeName; private final boolean ifExistsCondition; @@ -48,7 +45,6 @@ public class AlterPipe extends Statement { final boolean isReplaceAllExtractorAttributes, final boolean isReplaceAllProcessorAttributes, final boolean isReplaceAllConnectorAttributes) { - super(null); this.pipeName = requireNonNull(pipeName); this.ifExistsCondition = ifExistsCondition; this.extractorAttributes = requireNonNull(extractorAttributes); @@ -96,11 +92,6 @@ public class AlterPipe extends Statement { return visitor.visitAlterPipe(this, context); } - @Override - public List<? extends Node> getChildren() { - return ImmutableList.of(); - } - @Override public int hashCode() { return Objects.hash( diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java index ce7f3a2f4c5..cda5d9c5fd7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java @@ -19,16 +19,13 @@ package org.apache.iotdb.db.queryengine.plan.relational.sql.ast; -import com.google.common.collect.ImmutableList; - -import java.util.List; import java.util.Map; import java.util.Objects; import static com.google.common.base.MoreObjects.toStringHelper; import static java.util.Objects.requireNonNull; -public class CreatePipe extends Statement { +public class CreatePipe extends PipeStatement { private final String pipeName; private final boolean ifNotExistsCondition; @@ -42,7 +39,6 @@ public class CreatePipe extends Statement { final Map<String, String> extractorAttributes, final Map<String, String> processorAttributes, final Map<String, String> connectorAttributes) { - super(null); this.pipeName = requireNonNull(pipeName, "pipe name can not be null"); this.ifNotExistsCondition = ifNotExistsCondition; this.extractorAttributes = @@ -78,11 +74,6 @@ public class CreatePipe extends Statement { return visitor.visitCreatePipe(this, context); } - @Override - public List<? extends Node> getChildren() { - return ImmutableList.of(); - } - @Override public int hashCode() { return Objects.hash( diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipePlugin.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipePlugin.java index 58b5713b14e..676e360b3ab 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipePlugin.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipePlugin.java @@ -19,15 +19,12 @@ package org.apache.iotdb.db.queryengine.plan.relational.sql.ast; -import com.google.common.collect.ImmutableList; - -import java.util.List; import java.util.Objects; import static com.google.common.base.MoreObjects.toStringHelper; import static java.util.Objects.requireNonNull; -public class CreatePipePlugin extends Statement { +public class CreatePipePlugin extends PipeStatement { private final String pluginName; private final boolean ifNotExistsCondition; @@ -39,7 +36,6 @@ public class CreatePipePlugin extends Statement { final boolean ifNotExistsCondition, final String className, final String uriString) { - super(null); this.pluginName = requireNonNull(pluginName, "plugin name can not be null"); this.ifNotExistsCondition = ifNotExistsCondition; this.className = requireNonNull(className, "class name can not be null"); @@ -67,11 +63,6 @@ public class CreatePipePlugin extends Statement { return visitor.visitCreatePipePlugin(this, context); } - @Override - public List<? extends Node> getChildren() { - return ImmutableList.of(); - } - @Override public int hashCode() { return Objects.hash(pluginName, ifNotExistsCondition, className, uriString); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipe.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipe.java index fe48a9170a2..6952c06d13d 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipe.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipe.java @@ -19,21 +19,17 @@ package org.apache.iotdb.db.queryengine.plan.relational.sql.ast; -import com.google.common.collect.ImmutableList; - -import java.util.List; import java.util.Objects; import static com.google.common.base.MoreObjects.toStringHelper; import static java.util.Objects.requireNonNull; -public class DropPipe extends Statement { +public class DropPipe extends PipeStatement { private final String pipeName; private final boolean ifExistsCondition; public DropPipe(final String pipeName, final boolean ifExistsCondition) { - super(null); this.pipeName = requireNonNull(pipeName, "pipe name can not be null"); this.ifExistsCondition = ifExistsCondition; } @@ -51,11 +47,6 @@ public class DropPipe extends Statement { return visitor.visitDropPipe(this, context); } - @Override - public List<? extends Node> getChildren() { - return ImmutableList.of(); - } - @Override public int hashCode() { return Objects.hash(pipeName, ifExistsCondition); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipePlugin.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipePlugin.java index 3ba12a88b60..aaa7de52d21 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipePlugin.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DropPipePlugin.java @@ -19,21 +19,17 @@ package org.apache.iotdb.db.queryengine.plan.relational.sql.ast; -import com.google.common.collect.ImmutableList; - -import java.util.List; import java.util.Objects; import static com.google.common.base.MoreObjects.toStringHelper; import static java.util.Objects.requireNonNull; -public class DropPipePlugin extends Statement { +public class DropPipePlugin extends PipeStatement { private final String pluginName; private final boolean ifExistsCondition; public DropPipePlugin(final String pluginName, final boolean ifExistsCondition) { - super(null); this.pluginName = requireNonNull(pluginName, "plugin name can not be null"); this.ifExistsCondition = ifExistsCondition; } @@ -51,11 +47,6 @@ public class DropPipePlugin extends Statement { return visitor.visitDropPipePlugin(this, context); } - @Override - public List<? extends Node> getChildren() { - return ImmutableList.of(); - } - @Override public int hashCode() { return Objects.hash(pluginName, ifExistsCondition); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipePlugins.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/PipeStatement.java similarity index 67% copy from iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipePlugins.java copy to iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/PipeStatement.java index e4af4d857a6..2a7c9279f7e 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipePlugins.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/PipeStatement.java @@ -23,36 +23,14 @@ import com.google.common.collect.ImmutableList; import java.util.List; -import static com.google.common.base.MoreObjects.toStringHelper; +public abstract class PipeStatement extends Statement { -public class ShowPipePlugins extends Statement { - - public ShowPipePlugins() { + protected PipeStatement() { super(null); } - @Override - public <R, C> R accept(AstVisitor<R, C> visitor, C context) { - return visitor.visitShowPipePlugins(this, context); - } - @Override public List<? extends Node> getChildren() { return ImmutableList.of(); } - - @Override - public int hashCode() { - return 0; - } - - @Override - public boolean equals(Object obj) { - return obj instanceof ShowPipePlugins; - } - - @Override - public String toString() { - return toStringHelper(this).toString(); - } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipePlugins.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipePlugins.java index e4af4d857a6..115a554a227 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipePlugins.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipePlugins.java @@ -19,28 +19,15 @@ package org.apache.iotdb.db.queryengine.plan.relational.sql.ast; -import com.google.common.collect.ImmutableList; - -import java.util.List; - import static com.google.common.base.MoreObjects.toStringHelper; -public class ShowPipePlugins extends Statement { - - public ShowPipePlugins() { - super(null); - } +public class ShowPipePlugins extends PipeStatement { @Override public <R, C> R accept(AstVisitor<R, C> visitor, C context) { return visitor.visitShowPipePlugins(this, context); } - @Override - public List<? extends Node> getChildren() { - return ImmutableList.of(); - } - @Override public int hashCode() { return 0; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipes.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipes.java index 2710926e28c..e6507961093 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipes.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowPipes.java @@ -19,22 +19,18 @@ package org.apache.iotdb.db.queryengine.plan.relational.sql.ast; -import com.google.common.collect.ImmutableList; - import javax.annotation.Nullable; -import java.util.List; import java.util.Objects; import static com.google.common.base.MoreObjects.toStringHelper; -public class ShowPipes extends Statement { +public class ShowPipes extends PipeStatement { private final String pipeName; private final boolean hasWhereClause; public ShowPipes(final @Nullable String pipeName, final boolean hasWhereClause) { - super(null); this.pipeName = pipeName; this.hasWhereClause = hasWhereClause; } @@ -52,11 +48,6 @@ public class ShowPipes extends Statement { return visitor.visitShowPipes(this, context); } - @Override - public List<? extends Node> getChildren() { - return ImmutableList.of(); - } - @Override public int hashCode() { return Objects.hash(pipeName, hasWhereClause); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StartPipe.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StartPipe.java index a15a212ae17..540d6fef9ec 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StartPipe.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StartPipe.java @@ -19,20 +19,16 @@ package org.apache.iotdb.db.queryengine.plan.relational.sql.ast; -import com.google.common.collect.ImmutableList; - -import java.util.List; import java.util.Objects; import static com.google.common.base.MoreObjects.toStringHelper; import static java.util.Objects.requireNonNull; -public class StartPipe extends Statement { +public class StartPipe extends PipeStatement { private final String pipeName; public StartPipe(final String pipeName) { - super(null); this.pipeName = requireNonNull(pipeName, "pipe name can not be null"); } @@ -45,11 +41,6 @@ public class StartPipe extends Statement { return visitor.visitStartPipe(this, context); } - @Override - public List<? extends Node> getChildren() { - return ImmutableList.of(); - } - @Override public int hashCode() { return Objects.hash(pipeName); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StopPipe.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StopPipe.java index acd68edb2dd..daa9ab32e02 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StopPipe.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/StopPipe.java @@ -19,20 +19,16 @@ package org.apache.iotdb.db.queryengine.plan.relational.sql.ast; -import com.google.common.collect.ImmutableList; - -import java.util.List; import java.util.Objects; import static com.google.common.base.MoreObjects.toStringHelper; import static java.util.Objects.requireNonNull; -public class StopPipe extends Statement { +public class StopPipe extends PipeStatement { private final String pipeName; public StopPipe(final String pipeName) { - super(null); this.pipeName = requireNonNull(pipeName, "pipe name can not be null"); } @@ -45,11 +41,6 @@ public class StopPipe extends Statement { return visitor.visitStopPipe(this, context); } - @Override - public List<? extends Node> getChildren() { - return ImmutableList.of(); - } - @Override public int hashCode() { return Objects.hash(pipeName);
