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 2587c65a948 pipe sql
new 133b28060a4 pipe plugin sql
add 197965e9ae9 Skip the file timestamp check of tsfiles generated by
repair task (#13581)
add 737c4ccea98 Fix print error log when dir is not exist (#13591)
add 5b22e7b010b Handle commit failure of table procedures
new b506593d6e1 Merge branch 'master' of https://github.com/apache/iotdb
into pipe-table-model
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:
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../{ShowTablePlan.java => FetchTablePlan.java} | 17 +-
.../{ShowTableResp.java => FetchTableResp.java} | 21 +-
.../iotdb/confignode/manager/ConfigManager.java | 23 +++
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../iotdb/confignode/manager/ProcedureManager.java | 16 +-
.../manager/schema/ClusterSchemaManager.java | 16 ++
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../persistence/schema/ClusterSchemaInfo.java | 23 +++
.../confignode/persistence/schema/ConfigMTree.java | 17 ++
.../impl/schema/table/AddTableColumnProcedure.java | 1 -
.../impl/schema/table/CreateTableProcedure.java | 1 -
.../schema/table/SetTablePropertiesProcedure.java | 1 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 7 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 4 +
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 9 +
.../config/executor/ClusterConfigTaskExecutor.java | 22 ++-
.../config/executor/IConfigTaskExecutor.java | 4 +
.../fetcher/TableHeaderSchemaValidator.java | 60 ++++--
.../plan/relational/sql/ast/CreatePipe.java | 11 +-
.../ast/{CreatePipe.java => CreatePipePlugin.java} | 65 +++---
.../plan/relational/sql/ast/DropPipe.java | 2 +-
.../sql/ast/{DropPipe.java => DropPipePlugin.java} | 20 +-
.../ast/{NaturalJoin.java => ShowPipePlugins.java} | 30 +--
.../plan/relational/sql/ast/StartPipe.java | 2 +-
.../plan/relational/sql/ast/StopPipe.java | 2 +-
.../plan/relational/sql/parser/AstBuilder.java | 31 ++-
.../db/schemaengine/table/DataNodeTableCache.java | 217 ++++++++++++++++-----
.../db/storageengine/dataregion/DataRegion.java | 6 +-
.../execute/task/AbstractCompactionTask.java | 2 +-
.../task/InsertionCrossSpaceCompactionTask.java | 2 +
.../task/RepairUnsortedFileCompactionTask.java | 4 +
.../compaction/repair/RepairDataFileScanUtil.java | 10 +-
.../repair/RepairTimePartitionScanTask.java | 2 +-
.../dataregion/tsfile/TsFileResource.java | 2 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 4 +-
.../schema/table/TsTableInternalRPCUtil.java | 94 ++++++---
.../org/apache/iotdb/commons/utils/PathUtils.java | 7 +
.../src/main/thrift/confignode.thrift | 7 +
42 files changed, 591 insertions(+), 198 deletions(-)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/table/{ShowTablePlan.java
=> FetchTablePlan.java} (72%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/table/{ShowTableResp.java
=> FetchTableResp.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{CreatePipe.java
=> CreatePipePlugin.java} (54%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DropPipe.java
=> DropPipePlugin.java} (79%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{NaturalJoin.java
=> ShowPipePlugins.java} (78%)
