This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/joinOperator in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e0ec573d81592cbffb4a761436c299ad7f20d056 Merge: 9afbe466f01 14057a3cd93 Author: Beyyes <[email protected]> AuthorDate: Fri Sep 13 15:01:17 2024 +0800 Merge branch 'master' into beyyes/joinOperator .asf.yaml | 2 + .../org/apache/iotdb/db/it/IoTDBEncodingIT.java | 100 ++++++++++++- .../db/it/last/IoTDBLastQueryLastCacheIT.java | 14 ++ .../it/last/IoTDBLastQueryWithLimitOffsetIT.java | 34 +++++ .../iotdb/session/it/IoTDBSessionSimpleIT.java | 22 ++- .../api/customizer/parameter/PipeParameters.java | 4 + iotdb-client/client-py/SessionExample.py | 53 ++++++- iotdb-client/client-py/iotdb/Session.py | 33 ++++- .../client-py/iotdb/tsfile/utils/DateUtils.py | 53 +++---- iotdb-client/client-py/iotdb/utils/Field.py | 34 ++++- .../client-py/iotdb/utils/IoTDBConstants.py | 7 +- .../client-py/iotdb/utils/IoTDBRpcDataSet.py | 85 +++++++++-- iotdb-client/client-py/iotdb/utils/NumpyTablet.py | 30 +++- iotdb-client/client-py/iotdb/utils/RowRecord.py | 8 +- .../client-py/iotdb/utils/SessionDataSet.py | 24 ++-- iotdb-client/client-py/iotdb/utils/Tablet.py | 47 +++--- .../tests/integration/test_new_data_types.py | 157 +++++++++++++++++++++ .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 12 ++ .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 + .../client/IoTDBDataNodeAsyncClientManager.java | 12 +- .../connector/protocol/opcua/OpcUaNameSpace.java | 1 + .../protocol/opcua/OpcUaServerBuilder.java | 150 +++++++++++--------- .../PipeHistoricalDataRegionTsFileExtractor.java | 2 +- .../pipe/task/builder/PipeDataNodeTaskBuilder.java | 57 +++++++- .../plan/analyze/LoadTsFileAnalyzer.java | 55 +++++--- .../plan/planner/LogicalPlanVisitor.java | 11 +- .../plan/node/process/last/LastQueryNode.java | 3 + .../plan/node/write/InsertMultiTabletsNode.java | 2 +- .../plan/planner/plan/node/write/InsertNode.java | 2 +- .../planner/plan/node/write/InsertRowsNode.java | 4 +- .../plan/node/write/InsertRowsOfOneDeviceNode.java | 2 +- .../plan/relational/sql/parser/AstBuilder.java | 2 +- .../iotdb/db/schemaengine/SchemaEngineMode.java | 3 +- .../java/org/apache/iotdb/db/service/DataNode.java | 28 ++-- .../iotdb/db/service/DataNodeShutdownHook.java | 88 +++++------- .../db/storageengine/dataregion/DataRegion.java | 3 + .../task/RepairUnsortedFileCompactionTask.java | 63 +++++---- .../ReadChunkAlignedSeriesCompactionExecutor.java | 8 +- .../impl/NewSizeTieredCompactionSelector.java | 7 +- .../dataregion/memtable/DeviceIDFactory.java | 16 +-- .../dataregion/tsfile/TsFileManager.java | 14 ++ .../dataregion/tsfile/TsFileResource.java | 4 +- .../load/active/ActiveLoadDirScanner.java | 47 ++++++ .../load/active/ActiveLoadTsFileLoader.java | 19 ++- .../load/memory/LoadTsFileAbstractMemoryBlock.java | 4 + .../memory/LoadTsFileAnalyzeSchemaMemoryBlock.java | 28 +++- .../memory/LoadTsFileDataCacheMemoryBlock.java | 7 + .../load/memory/LoadTsFileMemoryManager.java | 28 +++- .../load/splitter/TsFileSplitter.java | 13 +- .../apache/iotdb/db/utils/ModificationUtils.java | 14 +- .../org/apache/iotdb/db/utils/SchemaUtils.java | 51 +------ .../logical/DataQueryLogicalPlannerTest.java | 33 +++++ .../TsFileResourceProgressIndexTest.java | 5 + ...nkCompactionPerformerWithAlignedSeriesTest.java | 32 +++++ .../apache/iotdb/db/utils/EnvironmentUtils.java | 4 - .../iotdb/commons/conf/CommonDescriptor.java | 3 - .../commons/consensus/index/ProgressIndex.java | 34 ++++- .../consensus/index/impl/HybridProgressIndex.java | 27 ++-- .../consensus/index/impl/IoTProgressIndex.java | 16 ++- .../consensus/index/impl/MetaProgressIndex.java | 8 +- .../consensus/index/impl/MinimumProgressIndex.java | 7 +- .../consensus/index/impl/RecoverProgressIndex.java | 25 +++- .../consensus/index/impl/SimpleProgressIndex.java | 12 +- .../consensus/index/impl/StateProgressIndex.java | 22 ++- .../index/impl/TimeWindowStateProgressIndex.java | 17 ++- pom.xml | 2 +- 66 files changed, 1282 insertions(+), 437 deletions(-)
