This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch support_table_model_redirect in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit db020af5f5c0674c6a89296422b874cb6fdec103 Merge: e025251a83a 6cca2e1b1e1 Author: HTHou <[email protected]> AuthorDate: Thu Sep 19 14:34:53 2024 +0800 Merge branch 'master' of github.com:apache/iotdb into support_table_model_redirect .../org/apache/iotdb/it/env/MultiEnvFactory.java | 11 +- .../iotdb/it/env/cluster/ClusterConstant.java | 10 - .../org/apache/iotdb/it/env/cluster/EnvUtils.java | 74 +- .../iotdb/it/env/cluster/env/AbstractEnv.java | 400 ++++----- .../iotdb/it/env/cluster/env/MultiClusterEnv.java | 8 +- .../it/env/cluster/node/AbstractNodeWrapper.java | 2 +- .../it/env/cluster/node/ConfigNodeWrapper.java | 35 +- .../iotdb/it/env/cluster/node/DataNodeWrapper.java | 32 +- .../db/it/aligned/IoTDBAlignedLastQueryIT.java | 113 +++ .../apache/iotdb/it/framework/IoTDBTestRunner.java | 21 +- .../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 6 + .../it/query/old/query/IoTDBArithmeticTableIT.java | 12 + .../relational/it/schema/IoTDBDatabaseIT.java | 44 +- .../iotdb/relational/it/schema/IoTDBTableIT.java | 4 +- .../consensus/request/ConfigPhysicalPlan.java | 4 + .../consensus/request/ConfigPhysicalPlanType.java | 1 + .../read/pipe/plugin/GetPipePluginJarPlan.java | 10 +- .../request/read/pipe/task/ShowPipePlanV2.java | 4 +- .../ShowTablePlan.java} | 28 +- .../response/pipe/task/PipeTableResp.java | 58 +- .../table/ShowTableResp.java} | 31 +- .../iotdb/confignode/manager/ConfigManager.java | 8 +- .../pipe/coordinator/task/PipeTaskCoordinator.java | 6 +- .../manager/schema/ClusterSchemaManager.java | 12 +- .../persistence/executor/ConfigPlanExecutor.java | 3 + .../persistence/schema/ClusterSchemaInfo.java | 35 +- .../request/ConfigPhysicalPlanSerDeTest.java | 282 ++++--- .../templates/ArithmeticColumnTransformerApi.ftl | 17 +- .../templates/ArithmeticUnaryColumnTransformer.ftl | 6 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 15 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 9 + .../evolvable/batch/PipeTabletEventBatch.java | 4 +- .../batch/PipeTransferBatchReqBuilder.java | 6 +- .../async/IoTDBDataRegionAsyncConnector.java | 7 +- .../thrift/sync/IoTDBDataRegionSyncConnector.java | 4 +- .../PipeHistoricalDataRegionTsFileExtractor.java | 28 +- .../db/pipe/metric/PipeDataRegionEventCounter.java | 6 +- .../resource/memory/InsertNodeMemoryEstimator.java | 913 +++++++++++++++++++++ .../subtask/connector/PipeConnectorSubtask.java | 12 +- .../connector/PipeConnectorSubtaskLifeCycle.java | 5 +- .../connector/PipeConnectorSubtaskManager.java | 6 +- .../PipeRealtimePriorityBlockingQueue.java | 7 +- .../execution/config/TableConfigTaskVisitor.java | 129 ++- .../config/executor/ClusterConfigTaskExecutor.java | 31 +- .../config/executor/IConfigTaskExecutor.java | 5 +- .../config/metadata/relational/CreateDBTask.java | 22 +- .../plan/planner/plan/node/write/InsertNode.java | 4 + .../plan/node/write/RelationalInsertRowNode.java | 3 +- .../plan/relational/sql/ast/CreateDB.java | 17 +- .../apache/iotdb/db/schemaengine/SchemaEngine.java | 60 +- .../db/schemaengine/table/DataNodeTableCache.java | 20 +- .../java/org/apache/iotdb/db/service/DataNode.java | 106 ++- .../dataregion/wal/utils/WALInsertNodeCache.java | 44 +- .../SubscriptionConnectorSubtaskLifeCycle.java | 2 +- .../SubscriptionConnectorSubtaskManager.java | 6 +- .../tools/schema/SchemaRegionSnapshotParser.java | 68 +- .../org/apache/iotdb/db/utils/DateTimeUtils.java | 9 +- .../db/utils/datastructure/AlignedTVList.java | 6 +- .../consensus/index/impl/IoTProgressIndex.java | 9 + .../pipe/connector/protocol/IoTDBConnector.java | 2 +- .../iotdb/commons/pipe/event/EnrichedEvent.java | 5 + .../pipe/task/connection/BlockingPendingQueue.java | 5 +- .../db/relational/grammar/sql/RelationalSql.g4 | 1 + 63 files changed, 2091 insertions(+), 762 deletions(-)
