This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch aidevicemanager
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit 6b1739f31a4 Update inference_request_pool.py
omit 12cd8da55ef bug fix & append it
omit b1e299bf790 fix pipeline bug
omit af998fe15f3 Update pool_controller.py
omit 34c3b1be05d Merge branch 'aidevicemanager' of
https://github.com/apache/iotdb into aidevicemanager
omit 5df97b42a3c resolve suggestions
omit 4077cec748d Apply suggestions from code review
omit 446c3876742 spotless
omit 8cb13f84cc0 append license
omit 391e1896cf9 seems finish
omit ece7eb71d77 stash
add e7ca49b3998 With clause enhance (#16353)
add d19455db6a0 Apply community-reviewed improvements from Ratis PR #1328
to vulnerability-check workflow (#16995)
add 8dc3a984ef7 [AINode] Upgrade urllib3 (#17002)
add 48dae279e7d No need to init TierManager when using
TsFileResourcePrinter (#17001)
add e78fcbfb54a ignore (#16991)
add 45aff042e02 Detect inconsistent chunk type when querying or compacting
tsfile & fix TsTable(TsTable origin) constructor (#16999)
add c563f9600a4 [AINode] Remove useless groovy check (#17003)
add b84be4d67c2 stash
add 71be1babc25 seems finish
add c0124f29978 append license
add 40e8456b678 spotless
add ab4ff9cf69a resolve suggestions
add 9e7132d20ca Apply suggestions from code review
add 14cce9e712b Update pool_controller.py
add 1a0d24957cb fix pipeline bug
add f05bdb6f715 bug fix & append it
add f50101ee246 Update inference_request_pool.py
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (6b1739f31a4)
\
N -- N -- N refs/heads/aidevicemanager (f50101ee246)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/vulnerability-check.yml | 42 +-
.../it/env/cluster/config/MppCommonConfig.java | 12 +
.../env/cluster/config/MppSharedCommonConfig.java | 14 +
.../it/env/remote/config/RemoteCommonConfig.java | 10 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +
.../relational/it/query/recent/IoTDBCteIT.java | 531 ++++++++++++++++-----
.../it/query/recent/IoTExplainAnalyzeIT.java | 264 ++++++++++
.../view/recent/IoTDBTableViewAddColumnTest.java | 84 ++++
iotdb-core/ainode/pom.xml | 34 --
iotdb-core/ainode/pyproject.toml | 2 +-
.../ainode/resources/syncPythonVersion.groovy | 159 ------
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 36 ++
.../ChunkTypeInconsistentException.java} | 30 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 3 +-
.../db/queryengine/common/MPPQueryContext.java | 128 ++++-
.../fragment/FragmentInstanceExecution.java | 33 +-
.../execution/fragment/QueryStatistics.java | 10 +-
.../execution/operator/ExplainAnalyzeOperator.java | 76 ++-
.../execution/operator/source/FileLoaderUtils.java | 9 +-
.../source/relational/CteScanOperator.java | 119 +++++
.../iotdb/db/queryengine/plan/Coordinator.java | 47 ++
.../queryengine/plan/analyze/AnalyzeVisitor.java | 4 +-
.../TableModelStatementMemorySourceVisitor.java | 34 +-
.../plan/planner/TableOperatorGenerator.java | 18 +
.../plan/planner/plan/DistributedQueryPlan.java | 11 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 20 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/relational/analyzer/Analysis.java | 31 ++
.../plan/relational/analyzer/Analyzer.java | 6 +
.../relational/analyzer/ExpressionAnalyzer.java | 8 +-
.../plan/relational/analyzer/Scope.java | 36 +-
.../relational/analyzer/StatementAnalyzer.java | 66 ++-
.../analyzer/StatementAnalyzerFactory.java | 4 +
.../plan/relational/planner/CteMaterializer.java | 355 ++++++++++++++
.../plan/relational/planner/QueryPlanner.java | 50 +-
.../plan/relational/planner/RelationPlanner.java | 135 ++++--
.../plan/relational/planner/SubqueryPlanner.java | 27 +-
.../relational/planner/TableLogicalPlanner.java | 28 +-
.../planner/distribute/AddExchangeNodes.java | 9 +
.../distribute/TableDistributedPlanner.java | 17 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 236 +++++++++
.../plan/relational/planner/node/CteScanNode.java | 132 +++++
.../PushLimitOffsetIntoTableScan.java | 7 +
.../optimizations/TransformSortToStreamSort.java | 7 +
.../optimizations/UnaliasSymbolReferences.java | 7 +
.../relational/sql/ast/ComparisonExpression.java | 22 +-
.../plan/relational/sql/ast/LongLiteral.java | 2 +-
.../queryengine/plan/relational/sql/ast/Query.java | 36 ++
.../plan/relational/sql/ast/WithQuery.java | 28 +-
.../plan/relational/sql/parser/AstBuilder.java | 11 +-
.../FragmentInstanceStatisticsDrawer.java | 26 +-
.../performer/impl/FastCompactionPerformer.java | 6 +-
.../execute/task/AbstractCompactionTask.java | 13 +
.../FastNonAlignedSeriesCompactionExecutor.java | 11 +
.../readchunk/SingleSeriesCompactionExecutor.java | 8 +
.../read/reader/chunk/DiskChunkLoader.java | 7 +
.../iotdb/db/tools/TsFileResourcePrinter.java | 5 +-
.../apache/iotdb/db/utils/cte/CteDataReader.java | 52 ++
.../apache/iotdb/db/utils/cte/CteDataStore.java | 109 +++++
.../apache/iotdb/db/utils/cte/MemoryReader.java | 75 +++
.../execution/operator/CteScanOperatorTest.java | 246 ++++++++++
.../plan/relational/analyzer/AnalyzerTest.java | 7 +
.../relational/analyzer/InsertIntoQueryTest.java | 7 +
.../analyzer/LimitOffsetPushDownTest.java | 7 +
.../analyzer/PushAggregationThroughUnionTest.java | 6 +
.../plan/relational/analyzer/SortTest.java | 7 +
.../plan/relational/analyzer/SubQueryTest.java | 7 +
.../relational/planner/CteMaterializerTest.java | 344 +++++++++++++
.../plan/relational/planner/CteSubqueryTest.java | 168 +++++++
.../plan/relational/planner/PlanTester.java | 37 +-
.../planner/UncorrelatedSubqueryTest.java | 261 ++++------
.../planner/assertions/AliasMatcher.java | 8 +
.../planner/assertions/ColumnReference.java | 13 +
.../planner/assertions/CteScanMatcher.java | 86 ++++
.../planner/assertions/DeviceTableScanMatcher.java | 11 +
.../planner/assertions/PlanMatchPattern.java | 28 ++
.../planner/assertions/RvalueMatcher.java | 8 +
.../planner/assertions/TableScanMatcher.java | 17 +
.../conf/iotdb-system.properties.template | 15 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 5 +
.../apache/iotdb/commons/schema/table/TsTable.java | 6 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 2 +-
.../src/main/thrift/datanode.thrift | 2 +
84 files changed, 4017 insertions(+), 614 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTExplainAnalyzeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBTableViewAddColumnTest.java
delete mode 100644 iotdb-core/ainode/resources/syncPythonVersion.groovy
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/compaction/selector/utils/DeviceInfo.java
=> exception/ChunkTypeInconsistentException.java} (58%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/CteScanOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/CteMaterializer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/ir/PredicateWithUncorrelatedScalarSubqueryReconstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/CteScanNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/cte/CteDataReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/cte/CteDataStore.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/cte/MemoryReader.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/CteScanOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/CteMaterializerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/CteSubqueryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/CteScanMatcher.java
