This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/join in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 028b750e0283188b5e1f8b2827a7bdc25293055c Merge: 35962d403ba 0840b23644c Author: Beyyes <[email protected]> AuthorDate: Thu Aug 15 10:36:28 2024 +0800 Merge branch 'master' into beyyes/join .../it/query/recent/IoTDBNullIdQueryIT.java | 24 +- .../iotdb/relational/it/schema/IoTDBTableIT.java | 19 ++ .../pipe/execution/PipeConfigNodeSubtask.java | 7 +- .../org/apache/iotdb/consensus/IStateMachine.java | 9 + .../apache/iotdb/consensus/iot/IoTConsensus.java | 2 + .../consensus/iot/IoTConsensusServerImpl.java | 39 +++ .../service/IoTConsensusRPCServiceProcessor.java | 21 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 97 +++++++ .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 86 +++++- .../dataregion/DataRegionStateMachine.java | 12 + .../iotdb/db/exception/LoadEmptyFileException.java | 4 +- .../execution/load/LoadTsFileManager.java | 10 + .../load/active/ActiveLoadDirScanner.java | 175 ++++++++++++ .../load/active/ActiveLoadPendingQueue.java | 64 +++++ .../load/active/ActiveLoadTsFileLoader.java | 310 +++++++++++++++++++++ .../load/{ => limiter}/LoadTsFileRateLimiter.java | 2 +- .../load/{ => splitter}/AlignedChunkData.java | 2 +- .../execution/load/{ => splitter}/ChunkData.java | 2 +- .../load/{ => splitter}/DeletionData.java | 2 +- .../load/{ => splitter}/NonAlignedChunkData.java | 2 +- .../execution/load/{ => splitter}/TsFileData.java | 2 +- .../load/{ => splitter}/TsFileSplitter.java | 2 +- .../relational/ColumnTransformerBuilder.java | 20 +- .../queryengine/plan/analyze/AnalyzeVisitor.java | 6 +- ...TsfileAnalyzer.java => LoadTsFileAnalyzer.java} | 23 +- .../execution/config/TableConfigTaskVisitor.java | 13 +- .../plan/node/load/LoadTsFilePieceNode.java | 2 +- .../relational/planner/ir/ExpressionRewriter.java | 9 +- .../planner/ir/ExpressionTreeRewriter.java | 8 + .../plan/scheduler/load/LoadTsFileScheduler.java | 6 +- .../iotdb/db/storageengine/StorageEngine.java | 2 +- .../db/storageengine/dataregion/DataRegion.java | 2 +- .../dataregion/memtable/AbstractMemTable.java | 47 ++++ .../storageengine/dataregion/tsfile/TsFileID.java | 6 +- .../dataregion/wal/buffer/WALEntry.java | 3 + .../dataregion/wal/buffer/WALEntryType.java | 7 +- .../file/AbstractTsFileRecoverPerformer.java | 5 + .../file/UnsealedTsFileRecoverPerformer.java | 1 + .../wal/recover/WALRecoverManagerTest.java | 82 ++++++ .../src/test/resources/oldwal/1723544967972-1-0-0 | Bin 0 -> 237 bytes .../datanode/src/test/resources/oldwal/_0-0-0.wal | Bin 0 -> 265150 bytes .../src/test/resources/oldwal/_0.checkpoint | Bin 0 -> 533 bytes .../datanode/src/test/resources/oldwal/_1-0-0.wal | Bin 0 -> 259747 bytes .../datanode/src/test/resources/oldwal/_2-0-0.wal | Bin 0 -> 36948 bytes .../datanode/src/test/resources/oldwal/_3-0-1.wal | Bin 0 -> 513 bytes .../conf/iotdb-system.properties.template | 44 ++- .../iotdb/commons/concurrent/ThreadName.java | 6 +- .../apache/iotdb/commons/conf/IoTDBConstant.java | 2 + .../commons/pipe/event/ProgressReportEvent.java | 5 + .../src/main/thrift/iotconsensus.thrift | 9 + 50 files changed, 1140 insertions(+), 61 deletions(-)
