This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/last_cache in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 9ddb0230c2814d9d0a998ca14f9d3990935b0890 Merge: 89a16f360a3 5f7b570aa5d Author: Beyyes <[email protected]> AuthorDate: Tue Dec 17 11:09:49 2024 +0800 Merge branch 'master' into beyyes/last_cache .../org/apache/iotdb/db/it/utils/TestUtils.java | 42 ++++ .../pipe/it/manual/IoTDBPipePermissionIT.java | 71 +++++- .../pipe/it/tablemodel/IoTDBPipeWithLoadIT.java | 246 +++++++++++++++++++++ .../org/apache/iotdb/tool/data/ExportData.java | 5 +- .../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 6 - .../iotdb/confignode/manager/ConfigManager.java | 4 +- .../iotdb/confignode/manager/ProcedureManager.java | 10 +- .../receiver/protocol/IoTDBConfigNodeReceiver.java | 119 ++++++++++ .../impl/schema/AlterLogicalViewProcedure.java | 108 ++++----- .../apache/iotdb/consensus/ratis/utils/Utils.java | 3 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 + .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 37 ++++ .../subtask/connector/PipeConnectorSubtask.java | 9 + .../async/IoTDBDataRegionAsyncConnector.java | 41 +++- .../PipeTransferTabletBatchEventHandler.java | 33 ++- .../PipeTransferTabletInsertNodeEventHandler.java | 14 +- .../PipeTransferTabletInsertionEventHandler.java | 62 +++--- .../handler/PipeTransferTabletRawEventHandler.java | 15 +- .../handler/PipeTransferTrackableHandler.java | 98 ++++++++ .../async/handler/PipeTransferTsFileHandler.java | 39 +++- .../PipeRealtimeDataRegionHybridExtractor.java | 11 +- .../realtime/assigner/PipeDataRegionAssigner.java | 18 +- .../protocol/thrift/IoTDBDataNodeReceiver.java | 26 ++- ...leStatementDataTypeConvertExecutionVisitor.java | 10 +- ...eeStatementDataTypeConvertExecutionVisitor.java | 10 +- .../iotdb/db/protocol/session/SessionManager.java | 4 +- .../analyze/load/LoadTsFileTableSchemaCache.java | 2 +- .../load/TreeSchemaAutoCreatorAndVerifier.java | 14 +- .../plan/planner/LocalExecutionPlanner.java | 9 + .../metadata/write/view/AlterLogicalViewNode.java | 47 ++-- .../plan/relational/metadata/Metadata.java | 6 +- .../relational/metadata/TableMetadataImpl.java | 9 +- .../fetcher/TableHeaderSchemaValidator.java | 41 +++- .../plan/relational/sql/ast/InsertRows.java | 3 +- .../relational/sql/ast/WrappedInsertStatement.java | 2 +- .../db/queryengine/plan/statement/Statement.java | 8 +- .../db/storageengine/load/LoadTsFileManager.java | 61 ++++- .../memory/LoadTsFileAnalyzeSchemaMemoryBlock.java | 4 +- .../memory/LoadTsFileDataCacheMemoryBlock.java | 41 +--- .../load/memory/LoadTsFileMemoryManager.java | 15 ++ .../plan/relational/analyzer/AnalyzerTest.java | 6 +- .../plan/relational/analyzer/TSBSMetadata.java | 6 +- .../plan/relational/analyzer/TestMatadata.java | 6 +- .../plan/statement/InsertStatementTest.java | 3 + .../apache/iotdb/commons/conf/CommonConfig.java | 9 + .../iotdb/commons/conf/CommonDescriptor.java | 5 + .../iotdb/commons/pipe/config/PipeConfig.java | 5 + .../resource/ref/PipePhantomReferenceManager.java | 2 +- .../apache/iotdb/commons/schema/table/TsTable.java | 15 ++ pom.xml | 6 + 51 files changed, 1140 insertions(+), 244 deletions(-)
