This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch throw-exception-connector in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit be6d3844744c247db8a0a207ef1eaface2482783 Author: Steve Yurong Su <[email protected]> AuthorDate: Mon Mar 18 21:16:56 2024 +0800 Update PipeStatementTSStatusVisitor.java --- .../iotdb/db/pipe/receiver/PipeStatementTSStatusVisitor.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTSStatusVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTSStatusVisitor.java index e2c8183f202..18b7a06b0c9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTSStatusVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTSStatusVisitor.java @@ -32,6 +32,7 @@ import org.apache.iotdb.db.queryengine.plan.statement.internal.InternalCreateMul import org.apache.iotdb.db.queryengine.plan.statement.internal.InternalCreateTimeSeriesStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.AlterTimeSeriesStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.CreateAlignedTimeSeriesStatement; +import org.apache.iotdb.db.queryengine.plan.statement.metadata.CreateMultiTimeSeriesStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.CreateTimeSeriesStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.ActivateTemplateStatement; import org.apache.iotdb.db.queryengine.plan.statement.metadata.template.BatchActivateTemplateStatement; @@ -105,6 +106,12 @@ public class PipeStatementTSStatusVisitor extends StatementVisitor<TSStatus, TSS return visitStatement(statement, context); } + @Override + public TSStatus visitCreateMultiTimeseries( + CreateMultiTimeSeriesStatement createMultiTimeSeriesStatement, TSStatus context) { + return visitGeneralInternalCreateTimeseries(createMultiTimeSeriesStatement, context); + } + @Override public TSStatus visitInternalCreateTimeseries( InternalCreateTimeSeriesStatement internalCreateTimeSeriesStatement, TSStatus context) {
