This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch win_metircs
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 44186dcbe8d update pom
add 2a591bd267b Pipe: Added parameter check to handshake of legacy
receiver (#16596)
add c72f67e80bf Pipe: Banned the audit / system DB from configNode sync
(#16592)
add 7db498025f0 Fix that ConcurrentLinkedDeque.removeIf is not actually
thread-safe (#16598)
add d49baf77096 Fix IoTDBClusterNodeShutdownHookIT (#16601)
add 8d933843dec Delete unused and vulnerable rpc interface (#16603)
add 46a0c6ac0b1 [AINode] Concurrent inference bug fix (#16595)
add 0d0b7d1e926 Fix aggregation query when device cross region in TreeModel
add fe96a5573dd Perfect implicit time process in first, last, first_by,
last_by of TableModel
add 2ae06e811bd Optimize memtable scan
add b20558f3158 Avoid NPE in the Procedure framework #16607
add 0df14b21190 Merge branch 'master' into win_metircs
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/node/AbstractNodeWrapper.java | 2 +
.../ainode/it/AINodeConcurrentInferenceIT.java | 71 +++----
.../iotdb/ainode/it/AINodeInferenceSQLIT.java | 4 +-
.../it/cluster/IoTDBClusterNodeShutdownHookIT.java | 2 +-
.../db/it/alignbydevice/IoTDBAlignByDevice2IT.java | 8 +-
.../db/it/alignbydevice/IoTDBAlignByDevice3IT.java | 8 +-
.../it/alignbydevice/IoTDBAlignByDevice4IT.java} | 13 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 34 +--
.../IoTDBAlignByDeviceWithTemplate2IT.java | 8 +-
.../IoTDBAlignByDeviceWithTemplate3IT.java} | 12 +-
...DBAlignByDeviceWithTemplateAggregation2IT.java} | 13 +-
...oTDBAlignByDeviceWithTemplateAggregationIT.java | 4 +-
.../IoTDBAlignByDeviceWithTemplateIT.java | 11 +-
.../IoTDBOrderByLimitOffsetAlignByDevice2IT.java | 8 +-
.../IoTDBOrderByLimitOffsetAlignByDevice3IT.java} | 17 +-
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 4 +-
.../IoTDBOrderByWithAlignByDevice2IT.java | 8 +-
.../IoTDBOrderByWithAlignByDevice3IT.java | 8 +-
.../IoTDBOrderByWithAlignByDevice4IT.java} | 13 +-
.../IoTDBOrderByWithAlignByDeviceIT.java | 4 +-
.../db/it/alignbydevice/IoTDBShuffleSink1IT.java | 8 +-
.../it/alignbydevice/IoTDBShuffleSink1_2IT.java} | 19 +-
.../db/it/alignbydevice/IoTDBShuffleSink2IT.java | 10 +-
.../it/alignbydevice/IoTDBShuffleSink2_2IT.java} | 21 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 9 +
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 3 +
.../treemodel/manual/IoTDBPipeInclusionIT.java | 46 ++---
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 39 +++-
.../core/inference/inference_request_pool.py | 22 +-
.../iotdb/ainode/core/inference/pool_controller.py | 21 +-
.../iotdb/ainode/core/inference/pool_group.py | 6 +
.../pool_scheduler/abstract_pool_scheduler.py | 9 +-
.../pool_scheduler/basic_pool_scheduler.py | 61 +++---
.../iotdb/ainode/core/manager/inference_manager.py | 6 +-
.../iotdb/ainode/core/manager/model_manager.py | 3 +
.../iotdb/ainode/core/model/model_storage.py | 7 +
.../consensus/response/model/GetModelInfoResp.java | 8 -
.../iotdb/confignode/manager/ModelManager.java | 38 +---
.../pipe/source/ConfigRegionListeningFilter.java | 20 ++
.../iotdb/confignode/persistence/ModelInfo.java | 2 -
.../schema/CNPhysicalPlanGenerator.java | 19 +-
.../confignode/persistence/schema/ConfigMTree.java | 8 +-
.../scheduler/AbstractProcedureScheduler.java | 2 +-
.../org/apache/iotdb/db/auth/LoginLockManager.java | 22 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 9 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 73 -------
.../fragment/FragmentInstanceContext.java | 20 ++
.../execution/operator/source/SeriesScanUtil.java | 65 +++++-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 10 +-
.../db/queryengine/plan/analyze/ModelFetcher.java | 23 +--
.../db/queryengine/plan/analyze/TemplatedInfo.java | 6 +-
.../visitor/ConcatDeviceVisitor.java} | 18 +-
.../plan/planner/OperatorTreeGenerator.java | 41 ++--
.../plan/planner/distribution/SourceRewriter.java | 76 +++++--
.../planner/plan/node/process/AggregationNode.java | 2 +-
.../plan/node/process/RawDataAggregationNode.java | 2 +-
.../node/source/SeriesAggregationSourceNode.java | 4 +-
.../parameter/model/ModelInferenceDescriptor.java | 5 +-
.../function/tvf/ForecastTableFunction.java | 14 +-
.../plan/relational/sql/parser/AstBuilder.java | 42 ++--
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 6 +-
.../read/reader/common/NoDataPointReader.java} | 38 ++--
.../db/tools/schema/SRStatementGenerator.java | 4 +-
.../db/utils/datastructure/AlignedTVList.java | 100 +++++----
.../iotdb/db/utils/datastructure/LazyBitMap.java | 93 +++++++++
.../db/utils/datastructure/MemPointIterator.java | 3 +
.../MergeSortMultiAlignedTVListIterator.java | 22 ++
.../MergeSortMultiTVListIterator.java | 22 ++
.../OrderedMultiAlignedTVListIterator.java | 24 +++
.../datastructure/OrderedMultiTVListIterator.java | 24 +++
.../iotdb/db/utils/datastructure/TVList.java | 229 ++++++++++++++++++++-
.../apache/iotdb/db/auth/LoginLockManagerTest.java | 2 +-
.../memtable/AlignedTVListIteratorTest.java | 110 ++++++++++
.../memtable/NonAlignedTVListIteratorTest.java | 87 ++++++++
.../iotdb/commons/schema/SchemaConstant.java | 6 +-
.../schema/column/ColumnHeaderConstant.java | 4 +-
.../thrift-datanode/src/main/thrift/client.thrift | 18 --
77 files changed, 1321 insertions(+), 542 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/{relational/it/db/it/IoTDBWindowFunction2IT.java
=> db/it/alignbydevice/IoTDBAlignByDevice4IT.java} (82%)
copy
integration-test/src/test/java/org/apache/iotdb/{relational/it/db/it/IoTDBWindowFunction2IT.java
=> db/it/alignbydevice/IoTDBAlignByDeviceWithTemplate3IT.java} (82%)
copy
integration-test/src/test/java/org/apache/iotdb/{relational/it/db/it/IoTDBWindowFunction2IT.java
=> db/it/alignbydevice/IoTDBAlignByDeviceWithTemplateAggregation2IT.java} (81%)
copy
integration-test/src/test/java/org/apache/iotdb/{relational/it/db/it/IoTDBWindowFunction2IT.java
=> db/it/alignbydevice/IoTDBOrderByLimitOffsetAlignByDevice3IT.java} (73%)
copy
integration-test/src/test/java/org/apache/iotdb/{relational/it/db/it/IoTDBWindowFunction2IT.java
=> db/it/alignbydevice/IoTDBOrderByWithAlignByDevice4IT.java} (81%)
copy
integration-test/src/test/java/org/apache/iotdb/{relational/it/db/it/IoTDBWindowFunction2IT.java
=> db/it/alignbydevice/IoTDBShuffleSink1_2IT.java} (68%)
copy
integration-test/src/test/java/org/apache/iotdb/{relational/it/db/it/IoTDBPatternAggregation2IT.java
=> db/it/alignbydevice/IoTDBShuffleSink2_2IT.java} (67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{planner/plan/node/source/SeriesSourceNode.java
=> expression/visitor/ConcatDeviceVisitor.java} (66%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/sql/ast/ShowAIDevices.java
=> storageengine/dataregion/read/reader/common/NoDataPointReader.java} (56%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/LazyBitMap.java
