This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch force_ci/support_schema_evolution
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from aba65887fe8 fix not overridden method
add 70930c362a3 fix unit test
add 5f641b262c3 Fix timeseries alias display in last for TreeModel (#17109)
add 256f2fce84f update chunk metadata after rewrite (#17110)
add ba95e5fd4c0 Set MQTT address to empty string. (#17111)
add 938f8149430 Pipe: add inclusion/exclusion pattern keys for pipe source
filtering (#17091)
add b2e15704661 Support build project by jdk25 (#17118)
add a61e01a5ce1 Use independent test folder for LocalFileRoleAccessorTest
(#17114)
add 743755cba8f Optimized the hint for subscription (#17115)
add 48ac5db7593 TimeFilter.canSkip() use getStatistics() method (#17119)
add 003f9b68d73 Support User Defined time column name (#17102)
add fd9134acc13 Add must override check (#17112)
add f0e47c03af5 Merge branch 'master' into
force_ci/support_schema_evolution
No new revisions were added by this update.
Summary of changes:
README.md | 4 +-
README_ZH.md | 4 +-
.../org/apache/iotdb/mqtt/MPPPublishHandler.java | 2 +-
.../iotdb/it/utils/TsFileTableGenerator.java | 30 ++-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 15 ++
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 10 +-
...stCache2IT.java => IoTDBLastQueryAlias2IT.java} | 2 +-
.../iotdb/db/it/last/IoTDBLastQueryAliasIT.java | 164 +++++++++++++
.../db/it/query/IoTDBAggregationFirstByIT.java | 109 +++++++++
.../it/query/IoTDBAggregationFirstByInGroupIT.java | 38 +++
.../iotdb/db/it/query/IoTDBAggregationFirstIT.java | 164 +++++++++++++
.../it/query/IoTDBAggregationFirstInGroupIT.java | 38 +++
.../db/it/query/IoTDBAggregationLastByIT.java | 108 +++++++++
.../it/query/IoTDBAggregationLastByInGroupIT.java | 34 +++
.../iotdb/db/it/query/IoTDBAggregationLastIT.java | 157 +++++++++++++
.../db/it/query/IoTDBAggregationLastInGroupIT.java | 38 +++
.../auto/basic/IoTDBTreePatternFormatIT.java | 258 +--------------------
.../treemodel/manual/IoTDBPipeInclusionIT.java | 13 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 1 +
.../relational/it/db/it/IoTDBLoadTsFileIT.java | 211 ++++++++++++++++-
.../it/rest/it/IoTDBRestServiceInsertValuesIT.java | 2 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 7 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 24 +-
.../it/schema/IoTDBTableWithDefinedTimeIT.java | 230 ++++++++++++++++++
iotdb-client/client-go | 2 +-
.../agent/plugin/PipeConfigNodePluginAgent.java | 4 +-
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 4 +-
.../confignode/persistence/schema/ConfigMTree.java | 12 +-
.../impl/region/AddRegionPeerProcedure.java | 2 +-
.../persistence/schema/ConfigMTreeTest.java | 3 +-
.../dataregion/PipeDataRegionPluginAgent.java | 18 +-
.../schemaregion/PipeSchemaRegionPluginAgent.java | 4 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 23 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 2 +-
.../pipe/agent/task/stage/PipeTaskSinkStage.java | 12 +-
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 6 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 2 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 10 +-
.../sink/protocol/opcda/OpcDaServerHandle.java | 4 +-
.../source/dataregion/IoTDBDataRegionSource.java | 9 +-
.../db/protocol/session/MqttClientSession.java | 6 +-
.../TableInsertTabletStatementGenerator.java | 10 +-
.../operator/process/TableIntoOperator.java | 7 +-
.../AlignedUpdateViewPathLastCacheOperator.java | 25 +-
.../process/last/UpdateLastCacheOperator.java | 2 +-
.../last/UpdateViewPathLastCacheOperator.java | 2 +-
.../relational/aggregation/AccumulatorFactory.java | 162 ++++++-------
.../execution/schedule/DriverScheduler.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 6 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 3 +
.../analyze/load/LoadTsFileTableSchemaCache.java | 12 +-
.../execution/config/TableConfigTaskVisitor.java | 78 ++++---
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../plan/planner/LogicalPlanBuilder.java | 48 +++-
.../plan/planner/LogicalPlanVisitor.java | 1 +
.../plan/planner/OperatorTreeGenerator.java | 27 ++-
.../plan/planner/TableOperatorGenerator.java | 79 +++++--
.../plan/planner/plan/node/PlanGraphPrinter.java | 7 +-
.../plan/node/load/LoadSingleTsFileNode.java | 18 +-
.../planner/plan/node/load/LoadTsFileNode.java | 15 +-
.../plan/node/process/last/LastQueryNode.java | 6 +-
.../plan/node/source/LastQueryScanNode.java | 104 ++++++---
.../relational/analyzer/ExpressionAnalyzer.java | 97 ++++++++
.../relational/analyzer/StatementAnalyzer.java | 28 ++-
.../plan/relational/metadata/Metadata.java | 22 +-
.../relational/metadata/TableMetadataImpl.java | 23 +-
.../fetcher/TableHeaderSchemaValidator.java | 96 ++++++--
.../plan/relational/planner/RelationPlanner.java | 1 +
.../plan/relational/planner/SubqueryPlanner.java | 2 +-
.../plan/relational/sql/ast/LoadTsFile.java | 11 +-
.../plan/relational/sql/parser/AstBuilder.java | 80 ++-----
.../relational/sql/util/ExpressionFormatter.java | 6 +-
.../schemaregion/utils/ResourceByPathUtils.java | 19 +-
.../db/schemaengine/table/DataNodeTableCache.java | 1 +
.../dataregion/memtable/ReadOnlyMemChunk.java | 4 +
.../task/stage/SubscriptionTaskSinkStage.java | 16 +-
.../subtask/SubscriptionSinkSubtaskManager.java | 37 ++-
.../org/apache/iotdb/db/utils/CommonUtils.java | 1 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 21 +-
.../iotdb/db/utils/TimestampPrecisionUtils.java | 4 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 2 +-
.../db/pipe/pattern/TreePatternPruningTest.java | 59 +++--
.../db/pipe/source/IoTDBDataRegionSourceTest.java | 4 -
.../process/window/function/FunctionTestUtils.java | 8 +-
.../distribution/AggregationTableScanTest.java | 177 ++++++++++++++
.../plan/planner/distribution/LastQueryTest.java | 3 +
.../logical/DataQueryLogicalPlannerTest.java | 11 +-
.../plan/planner/node/load/LoadTsFileNodeTest.java | 2 +-
.../planner/node/source/SourceNodeSerdeTest.java | 2 +
.../plan/relational/analyzer/AggregationTest.java | 2 +-
.../plan/relational/analyzer/AnalyzerTest.java | 8 +-
.../plan/relational/analyzer/AsofJoinTest.java | 2 +-
.../plan/relational/analyzer/BaseAnalyzerTest.java | 34 +--
.../plan/relational/analyzer/DistinctTest.java | 2 +-
.../relational/analyzer/InsertIntoQueryTest.java | 2 +-
.../plan/relational/analyzer/JoinTest.java | 2 +-
.../analyzer/LimitOffsetPushDownTest.java | 2 +-
.../analyzer/PushAggregationThroughUnionTest.java | 2 +-
.../plan/relational/analyzer/SortTest.java | 2 +-
.../plan/relational/analyzer/SubQueryTest.java | 2 +-
.../plan/relational/analyzer/TSBSMetadata.java | 6 +-
.../relational/analyzer/TableFunctionTest.java | 2 +-
.../plan/relational/analyzer/TestMetadata.java | 6 +-
.../plan/relational/planner/CteSubqueryTest.java | 3 +-
.../plan/relational/planner/ExampleTest.java | 3 +-
.../planner/UncorrelatedSubqueryTest.java | 3 +-
.../planner/WindowFunctionOptimizationTest.java | 3 +-
.../relational/planner/WindowFunctionTest.java | 3 +-
.../plan/statement/InsertStatementTest.java | 16 +-
.../tsfile/evolution/SchemaEvolutionFileTest.java | 2 +-
.../org/apache/iotdb/db/utils/AnnotationTest.java | 59 +++++
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 12 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 68 +++---
.../pipe/config/constant/PipeSourceConstant.java | 2 +
.../pipe/datastructure/pattern/TreePattern.java | 198 ++++++++++++----
.../commons/schema/table/InformationSchema.java | 19 --
.../schema/table/TsFileTableSchemaUtil.java | 30 ++-
.../apache/iotdb/commons/schema/table/TsTable.java | 6 -
.../schema/table/column/TsTableColumnCategory.java | 4 +
.../schema/table/TsFileTableSchemaUtilTest.java | 16 +-
pom.xml | 8 +-
121 files changed, 2715 insertions(+), 953 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/last/{IoTDBLastQueryLastCache2IT.java
=> IoTDBLastQueryAlias2IT.java} (96%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryAliasIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableWithDefinedTimeIT.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/AggregationTableScanTest.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBAlignByDevice4IT.java
=>
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/BaseAnalyzerTest.java
(51%)
