This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1ded38ce5fd Optimized the error log for illegal database names in tree
model
add 98addd823bc Pipe: basic support for table model from SQL to
IConfigTask (#13600)
No new revisions were added by this update.
Summary of changes:
.../execution/config/TableConfigTaskVisitor.java | 72 +++++++
.../config/metadata/CreatePipePluginTask.java | 10 +
.../config/metadata/DropPipePluginTask.java | 7 +
.../execution/config/sys/pipe/AlterPipeTask.java | 14 ++
.../execution/config/sys/pipe/CreatePipeTask.java | 11 ++
.../execution/config/sys/pipe/DropPipeTask.java | 8 +
.../execution/config/sys/pipe/ShowPipeTask.java | 7 +
.../execution/config/sys/pipe/StartPipeTask.java | 7 +
.../execution/config/sys/pipe/StopPipeTask.java | 7 +
.../relational/analyzer/StatementAnalyzer.java | 54 ++++++
.../plan/relational/sql/ast/AlterPipe.java | 152 +++++++++++++++
.../plan/relational/sql/ast/AstVisitor.java | 36 ++++
.../plan/relational/sql/ast/CreatePipe.java | 122 ++++++++++++
.../{CreateFunction.java => CreatePipePlugin.java} | 76 ++++----
.../sql/ast/{Values.java => DropPipe.java} | 45 ++---
.../sql/ast/{Values.java => DropPipePlugin.java} | 45 ++---
.../ast/{NaturalJoin.java => ShowPipePlugins.java} | 29 +--
.../sql/ast/{Values.java => ShowPipes.java} | 48 ++---
.../sql/ast/{JoinUsing.java => StartPipe.java} | 48 ++---
.../sql/ast/{JoinUsing.java => StopPipe.java} | 48 ++---
.../plan/relational/sql/parser/AstBuilder.java | 192 +++++++++++++++++++
.../plan/relational/sql/util/SqlFormatter.java | 208 +++++++++++++++++++++
.../config/constant/PipeExtractorConstant.java | 6 +
.../db/relational/grammar/sql/RelationalSql.g4 | 138 +++++++++++++-
24 files changed, 1224 insertions(+), 166 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AlterPipe.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{CreateFunction.java
=> CreatePipePlugin.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Values.java
=> DropPipe.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Values.java
=> DropPipePlugin.java} (59%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{NaturalJoin.java
=> ShowPipePlugins.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Values.java
=> ShowPipes.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{JoinUsing.java
=> StartPipe.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{JoinUsing.java
=> StopPipe.java} (69%)
