This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-table-model
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 208310e9696 Update RelationalSql.g4
add 5de8dc7a4db IoTConsensusV2: Introduce IoTConsensusV2 and corresponding
mode option (#13440)
add acda1a0f092 Make log dispatcher stop in parallel #13588
add cb4befcbd45 fix bug (#13590)
add 24d1191a8e7 Fix potential NPE when write FileTimeIndexCache (#13583)
new 04783e04f99 Merge branch 'master' of https://github.com/apache/iotdb
into pipe-table-model
new 2587c65a948 pipe sql
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../iotdb/it/env/cluster/ClusterConstant.java | 4 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 18 +--
.../confignode/conf/ConfigNodeStartupCheck.java | 5 +-
.../manager/load/balancer/RouteBalancer.java | 3 -
.../apache/iotdb/consensus/ConsensusFactory.java | 23 +--
.../consensus/config/PipeConsensusConfig.java | 26 +++-
.../consensus/iot/logdispatcher/LogDispatcher.java | 11 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 40 +++--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 26 ++--
.../db/consensus/DataRegionConsensusImpl.java | 4 +-
.../agent/receiver/PipeDataNodeReceiverAgent.java | 2 +-
.../pipeconsensus/PipeConsensusAsyncConnector.java | 4 +-
.../pipeconsensus/PipeConsensusReceiver.java | 13 +-
.../plan/planner/plan/node/write/InsertNode.java | 1 -
.../plan/relational/sql/ast/AlterPipe.java | 153 +++++++++++++++++++
.../plan/relational/sql/ast/CreatePipe.java | 120 +++++++++++++++
.../sql/ast/{Values.java => DropPipe.java} | 46 +++---
.../sql/ast/{Values.java => ShowPipes.java} | 49 +++---
.../sql/ast/{ShowDataNodes.java => StartPipe.java} | 27 ++--
.../ast/{ShowConfigNodes.java => StopPipe.java} | 27 ++--
.../plan/relational/sql/parser/AstBuilder.java | 167 +++++++++++++++++++++
.../java/org/apache/iotdb/db/service/DataNode.java | 3 +-
.../iotdb/db/storageengine/StorageEngine.java | 3 -
.../db/storageengine/dataregion/DataRegion.java | 4 +-
.../FileTimeIndexCacheWriter.java | 8 +-
.../storageengine/dataregion/wal/WALManager.java | 18 +--
.../dataregion/wal/recover/WALNodeRecoverTask.java | 7 +-
.../conf/iotdb-system.properties.template | 25 ++-
.../assembly/resources/sbin/destroy-datanode.bat | 12 +-
.../assembly/resources/sbin/destroy-datanode.sh | 4 +-
30 files changed, 656 insertions(+), 197 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/{Values.java
=> DropPipe.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Values.java
=> ShowPipes.java} (60%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowDataNodes.java
=> StartPipe.java} (69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowConfigNodes.java
=> StopPipe.java} (69%)
