This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch strong_password
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 5d8447ed151 fix its
add f0a9baab5da fix its
add 0927009a779 [AINode] Fix the seed when inference (#15850)
add 71df4956ef0 Subscription: intro poll and prefetch v2 for tsfile topic
(#15790)
add be7a1de2b45 [AINode] Fix bug that AINode cannot register and invoke
user_defined model (#15849)
add b1429293894 Fix the issue that symbol name is not found in tree view
scan & Querying a time range with no data may throw an exception
add c30af2c6b53 Add size control of result for
SimpleNestedLoopCrossJoinOperator
add e69fc997803 Pipe: Fixed the class cast exception of the table view
meta sync (#15855)
add 5cda97b25d5 Support aggregation functions in RPR
add d86b86e87c4 Merge LastQueryScanNode of same device
add 03e701860ad [AINode] Add window_step options for dataset (#15857)
add bfcf56bc4fe Merge branch 'master' into strong_password
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppCommonConfig.java | 17 +
.../env/cluster/config/MppSharedCommonConfig.java | 19 +
.../it/env/remote/config/RemoteCommonConfig.java | 12 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../manual/basic/IoTDBPipeExtractorIT.java | 17 +-
.../manual/basic/IoTDBPipePermissionIT.java | 9 +-
.../treemodel/auto/basic/IoTDBPipeExtractorIT.java | 39 +-
.../pipe/it/single/IoTDBPipePermissionIT.java | 4 +-
.../it/db/it/IoTDBPatternAggregationIT.java | 492 +++++++++++++++++++++
.../query/view/recent/IoTDBTableViewQueryIT.java | 17 +
.../it/triple/AbstractSubscriptionTripleIT.java | 7 +
.../AbstractSubscriptionTreeRegressionIT.java | 71 ++-
.../IoTDBRootPullConsumeTsfileIT.java | 15 +-
.../format/IoTDBDBTsfilePullConsumerIT.java | 18 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 16 +-
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 14 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 17 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 17 +-
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 16 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 33 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 39 +-
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 15 +-
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 14 +-
.../IoTDBRootPatternPullConsumeTsfileIT.java | 12 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 15 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 8 +
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 11 +
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 4 +-
iotdb-core/ainode/ainode/core/ingress/dataset.py | 2 +
iotdb-core/ainode/ainode/core/ingress/iotdb.py | 40 +-
.../ainode/core/manager/inference_manager.py | 6 +
.../ainode/ainode/core/model/model_storage.py | 79 +++-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 4 +-
.../db/queryengine/common/MPPQueryContext.java | 29 ++
.../execution/MemoryEstimationHelper.java | 28 ++
.../execution/fragment/DataNodeQueryContext.java | 21 +-
.../process/PatternRecognitionOperator.java | 8 +
.../join/SimpleNestedLoopCrossJoinOperator.java | 3 +-
.../last/AbstractUpdateLastCacheOperator.java | 24 +-
.../last/AlignedUpdateLastCacheOperator.java | 10 +-
.../AlignedUpdateViewPathLastCacheOperator.java | 6 +-
.../operator/process/last/LastQueryOperator.java | 1 +
.../process/last/LastQuerySortOperator.java | 10 +-
.../process/last/UpdateLastCacheOperator.java | 23 +-
.../rowpattern/PatternAggregationTracker.java | 156 +++++++
.../process/rowpattern/PatternAggregator.java | 178 ++++++++
.../process/rowpattern/PatternAggregators.java | 74 ++++
.../rowpattern/PatternPartitionExecutor.java | 13 +
.../rowpattern/PatternVariableRecognizer.java | 8 +-
...cessor.java => PhysicalAggregationPointer.java} | 12 +-
.../process/rowpattern/expression/Computation.java | 15 +-
.../expression/PatternExpressionComputation.java | 18 +-
.../process/rowpattern/matcher/Matcher.java | 29 +-
.../db/queryengine/plan/analyze/Analysis.java | 33 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 72 ++-
.../queryengine/plan/analyze/ExpressionUtils.java | 14 +-
.../memory/StatementMemorySourceVisitor.java | 3 +-
.../plan/planner/LogicalPlanBuilder.java | 150 +++----
.../plan/planner/OperatorTreeGenerator.java | 146 +++---
.../plan/planner/SubPlanTypeExtractor.java | 6 -
.../plan/planner/TableOperatorGenerator.java | 159 ++++++-
.../planner/distribution/ExchangeNodeAdder.java | 15 +-
.../planner/distribution/NodeGroupContext.java | 12 +
.../SimpleFragmentParallelPlanner.java | 12 +-
.../plan/planner/distribution/SourceRewriter.java | 152 +++++--
.../plan/planner/plan/node/PlanGraphPrinter.java | 18 +-
.../plan/planner/plan/node/PlanNodeType.java | 14 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 -
.../plan/node/process/MultiChildProcessNode.java | 4 +
.../plan/node/process/last/LastQueryNode.java | 141 +++++-
.../plan/node/source/AlignedLastQueryScanNode.java | 245 ----------
.../plan/node/source/LastQueryScanNode.java | 193 ++++++--
.../relational/analyzer/ExpressionAnalyzer.java | 155 ++++++-
.../plan/relational/planner/RelationPlanner.java | 57 ++-
.../distribute/TableDistributedPlanGenerator.java | 4 +
.../planner/optimizations/SymbolMapper.java | 39 +-
.../planner/rowpattern/AggregationLabelSet.java | 100 +++++
.../rowpattern/AggregationValuePointer.java | 161 +++++++
.../rowpattern/ExpressionAndValuePointers.java | 16 +
.../db/subscription/broker/SubscriptionBroker.java | 35 +-
.../broker/SubscriptionPrefetchingQueue.java | 387 +++++++++++++++-
.../broker/SubscriptionPrefetchingTabletQueue.java | 7 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 6 -
.../SubscriptionPipeEventBatchSegmentLock.java} | 55 +--
.../event/batch/SubscriptionPipeEventBatches.java | 118 ++---
.../batch/SubscriptionPipeTsFileEventBatch.java | 40 +-
.../receiver/SubscriptionReceiverV1.java | 2 +
.../execution/operator/LastQueryOperatorTest.java | 6 +-
.../operator/LastQueryTreeSortOperatorTest.java | 6 +-
.../operator/process/rowpattern/MatcherTest.java | 4 +-
.../plan/planner/distribution/LastQueryTest.java | 22 +-
.../logical/DataQueryLogicalPlannerTest.java | 86 ++--
...deTest.java => LastQueryScanNodeSerdeTest.java} | 51 ++-
.../plan/relational/analyzer/JoinTest.java | 136 ++++++
.../apache/iotdb/commons/conf/CommonConfig.java | 4 +-
.../iotdb/commons/partition/DataPartition.java | 11 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +
97 files changed, 3570 insertions(+), 1107 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBPatternAggregationIT.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/rowpattern/PatternAggregationTracker.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/rowpattern/PatternAggregator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/rowpattern/PatternAggregators.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/rowpattern/{PhysicalValueAccessor.java
=> PhysicalAggregationPointer.java} (79%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/AlignedLastQueryScanNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/rowpattern/AggregationLabelSet.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/rowpattern/AggregationValuePointer.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/resource/tsfile/PipeTsFileResourceSegmentLock.java
=> subscription/event/batch/SubscriptionPipeEventBatchSegmentLock.java} (60%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/source/{SeriesScanNodeSerdeTest.java
=> LastQueryScanNodeSerdeTest.java} (55%)
