This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 94218982193 fix ttl deletion
new 8381e63ea0d Fix the issue that the DeviceIteratorScanOperator.next()
method throws NoSuchElementException
new 85232687137 Revert Pipe/IoTV2: Try to persist progressIndex in local
for resend event more efficently (#15924)
new 0a5f1ebbbb8 [AINode] Support model management for Table (#15923)
new bb03e0523dc Bump org.apache.commons:commons-lang3 from 3.13.0 to
3.18.0 (#15922)
new 3ecf97310c8 Make div and mod return long type if types of two inputs
are all int64 or int32
new 78c382298e5 Fix timestamp type data conversion issue in exported data
of table model (#15918)
new be06663ff4a Fix display of Blob type in last query
new 6c454753ead Fix explicit time query process in TreeModel
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/iotdb/ainode/it/AINodeBasicIT.java | 268 -------------------
.../it/AINodeClusterConfigIT.java} | 41 +--
.../iotdb/ainode/it/AINodeInferenceSQLIT.java | 292 +++++++++++++++++++++
.../iotdb/ainode/it/AINodeModelManageIT.java | 215 +++++++++++++++
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 126 +++++++++
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 4 +-
.../maxby/IoTDBMaxByAlignedSeriesIT.java | 20 ++
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 21 +-
.../db/it/aggregation/minby/IoTDBMinByIT.java | 5 +-
.../db/it/last/IoTDBLastQueryLastCacheIT.java | 15 +-
.../IoTDBArithmeticDivAndModWithoutDoubleIT.java} | 34 +--
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 48 ++--
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 48 ++--
.../src/test/resources/ainode-example/config.yaml | 8 +-
.../apache/iotdb/tool/data/ExportDataTable.java | 5 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../iotdb/confignode/manager/ModelManager.java | 2 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 2 -
.../confignode/persistence/pipe/PipeTaskInfo.java | 7 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 4 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 16 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 18 +-
.../confignode/service/ConfigNodeShutdownHook.java | 3 -
.../request/ConfigPhysicalPlanSerDeTest.java | 12 +-
.../consensus/response/pipe/PipeTableRespTest.java | 6 +-
.../agent/PipeConfigNodeSubtaskExecutorTest.java | 3 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 4 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 27 --
...oricalDataRegionTsFileAndDeletionExtractor.java | 9 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 8 +-
.../operator/process/ProjectOperator.java | 3 +-
.../last/AlignedUpdateLastCacheOperator.java | 4 +-
.../AlignedUpdateViewPathLastCacheOperator.java | 4 +-
.../process/last/LastQueryTransformOperator.java | 4 +-
.../operator/process/last/LastQueryUtil.java | 34 +++
.../process/last/UpdateLastCacheOperator.java | 4 +-
.../last/UpdateViewPathLastCacheOperator.java | 4 +-
.../relational/DeviceIteratorScanOperator.java | 3 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 4 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 8 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 29 ++
.../execution/config/TableConfigTaskVisitor.java | 23 ++
.../execution/config/TreeConfigTaskVisitor.java | 14 +-
.../config/executor/ClusterConfigTaskExecutor.java | 17 +-
.../config/executor/IConfigTaskExecutor.java | 8 +-
.../config/metadata/ai/CreateModelTask.java | 14 +-
.../visitor/ColumnTransformerVisitor.java | 11 +
.../db/queryengine/plan/parser/ASTVisitor.java | 26 +-
.../plan/planner/OperatorTreeGenerator.java | 14 +-
.../plan/relational/sql/ast/AstVisitor.java | 8 +
.../sql/ast/{ShowModels.java => CreateModel.java} | 48 ++--
.../plan/relational/sql/ast/CreateTraining.java | 27 +-
.../sql/ast/{ShowModels.java => DropModel.java} | 44 ++--
.../plan/relational/sql/parser/AstBuilder.java | 66 +++--
.../plan/statement/crud/QueryStatement.java | 10 +-
.../metadata/model/CreateModelStatement.java | 10 +-
.../metadata/model/DropModelStatement.java | 10 +-
.../metadata/model/ShowModelsStatement.java | 12 +-
.../dag/input/QueryDataSetInputLayer.java | 3 +
.../iotdb/db/service/DataNodeShutdownHook.java | 3 -
.../db/queryengine/plan/analyze/AnalyzeTest.java | 4 +-
.../iotdb/commons/concurrent/ThreadName.java | 5 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 55 ----
.../agent/runtime/PipePeriodicalJobExecutor.java | 33 ---
.../commons/pipe/agent/task/PipeTaskAgent.java | 3 -
.../commons/pipe/agent/task/meta/PipeMeta.java | 6 +-
.../pipe/agent/task/meta/PipeRuntimeMeta.java | 51 +---
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 142 +---------
.../iotdb/commons/pipe/config/PipeConfig.java | 21 --
.../iotdb/commons/pipe/config/PipeDescriptor.java | 18 --
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 22 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 8 +-
pom.xml | 2 +-
73 files changed, 1146 insertions(+), 966 deletions(-)
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeBasicIT.java
copy
integration-test/src/test/java/org/apache/iotdb/{db/it/IoTDBExampleIT.java =>
ainode/it/AINodeClusterConfigIT.java} (60%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeInferenceSQLIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeModelManageIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/utils/AINodeTestUtils.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{groupby/IoTDBLeftORightCIT.java
=> query/IoTDBArithmeticDivAndModWithoutDoubleIT.java} (67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowModels.java
=> CreateModel.java} (66%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowModels.java
=> DropModel.java} (65%)
