This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch rc/2.0.6
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 460f3e90bb0 [AINode] Fix pom.xml of ainode (#16375)
new a1ee17ceac5 [AINode] Refactor code base
new 9272ef6c2c6 [AINode] Implement concurrent inference framework (#16311)
new 49fbdbcbda7 [AINode] Fix bugs for SHOW LOADED MODELS (#16410)
new 4e42ba6b525 [AINode] Add a batcher for inference (#16411)
new c7a614c8ccf [AINode][Bug fix] Concurrent inference (#16518)
new 68e44cca191 [AINode] Concurrent inference bug fix (#16595)
new 9bd8328f24d [AINode] Adjust the maximum inference input length (#16640)
new 048abac28f0 [AINode] Fix bug of sundial and forecast udf (#16768)
new 6ec4bcfc541 [AINode] Package AINode via PyInstaller (#16707)
new 533087eb5a5 [AINode] Enable AINode start as background (-d) (#16762)
new c163b93165f [AINode] Update AINodeClient for DataNode to borrow
(#16647)
new 3eecb8adcdd [AINode] Fix bug that AINode cannot compile in Windows
(#16767)
new e70b66dc09b [AINode] Delete poetry.lock for easier maintain different
operating systems (#16793)
new 3cfcc7518b0 [AINode] Fix cp errors
new 8f6d4b5076e [AINode] Bump version to 2.0.6
The 15 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:
.github/workflows/cluster-it-1c1d1a.yml | 5 +-
integration-test/src/assembly/mpp-test.xml | 2 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 27 +-
.../ainode/it/AINodeConcurrentInferenceIT.java | 181 ++
.../iotdb/ainode/it/AINodeInferenceSQLIT.java | 4 +-
.../ainode/it/AINodeInstanceManagementIT.java | 212 ++
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 35 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../client-py => iotdb-core/ainode}/.flake8 | 2 +-
iotdb-core/ainode/.gitignore | 11 +-
iotdb-core/ainode/ainode.spec | 199 ++
iotdb-core/ainode/ainode.xml | 17 +-
iotdb-core/ainode/ainode/__init__.py | 0
.../core/inference/inference_request_pool.py | 197 --
iotdb-core/ainode/ainode/core/rpc/handler.py | 76 -
iotdb-core/ainode/ainode/core/script.py | 110 -
iotdb-core/ainode/build_binary.py | 602 +++++
iotdb-core/ainode/iotdb/Session.py | 33 +-
.../{ainode/core => iotdb/ainode}/__init__.py | 0
iotdb-core/ainode/iotdb/ainode/conf/git.properties | 3 -
.../inference => iotdb/ainode/core}/__init__.py | 0
.../ainode/{ => iotdb}/ainode/core/ai_node.py | 29 +-
.../ainode/{ => iotdb}/ainode/core/config.py | 107 +-
.../ainode/{ => iotdb}/ainode/core/constant.py | 35 +-
.../ainode/{ => iotdb}/ainode/core/exception.py | 9 +-
.../ainode/core/inference}/__init__.py | 0
.../ainode/core/inference/batcher}/__init__.py | 0
.../core/inference/batcher/abstract_batcher.py | 35 +-
.../ainode/core/inference/batcher/basic_batcher.py | 63 +
.../ainode/core/inference/dispatcher}/__init__.py | 0
.../inference/dispatcher/abstract_dispatcher.py} | 49 +-
.../core/inference/dispatcher/basic_dispatcher.py | 60 +
.../ainode/core/inference/inference_request.py | 18 +-
.../core/inference/inference_request_pool.py | 223 ++
.../iotdb/ainode/core/inference/pool_controller.py | 519 ++++
.../iotdb/ainode/core/inference/pool_group.py | 121 +
.../core/inference/pool_scheduler}/__init__.py | 0
.../pool_scheduler/abstract_pool_scheduler.py | 86 +
.../pool_scheduler/basic_pool_scheduler.py | 193 ++
.../core/inference/request_scheduler}/__init__.py | 0
.../abstract_request_scheduler.py} | 2 +-
.../request_scheduler/basic_request_scheduler.py} | 11 +-
.../ainode/core/inference/strategy}/__init__.py | 0
.../strategy/abstract_inference_pipeline.py | 0
.../strategy/timer_sundial_inference_pipeline.py | 6 +-
.../strategy/timerxl_inference_pipeline.py | 12 +-
.../{ => iotdb}/ainode/core/inference/utils.py | 0
.../ainode/core/ingress}/__init__.py | 0
.../{ => iotdb}/ainode/core/ingress/dataset.py | 0
.../{ => iotdb}/ainode/core/ingress/iotdb.py | 22 +-
iotdb-core/ainode/{ => iotdb}/ainode/core/log.py | 8 +-
.../rpc => iotdb/ainode/core/manager}/__init__.py | 0
.../ainode/core/manager/cluster_manager.py | 7 +-
.../ainode/core/manager/inference_manager.py | 254 +-
.../ainode/core/manager/model_manager.py | 38 +-
.../{ => iotdb}/ainode/core/manager/utils.py | 35 +-
.../util => iotdb/ainode/core/model}/__init__.py | 0
.../ainode/core/model/built_in_model_factory.py | 54 +-
.../{ => iotdb}/ainode/core/model/model_enums.py | 0
.../{ => iotdb}/ainode/core/model/model_factory.py | 14 +-
.../{ => iotdb}/ainode/core/model/model_info.py | 4 +-
.../{ => iotdb}/ainode/core/model/model_storage.py | 37 +-
.../iotdb/ainode/core/model/sundial}/__init__.py | 0
.../core/model/sundial/configuration_sundial.py | 0
.../ainode/core/model/sundial/flow_loss.py | 0
.../ainode/core/model/sundial/modeling_sundial.py | 23 +-
.../core/model/sundial/ts_generation_mixin.py | 0
.../iotdb/ainode/core/model/timerxl}/__init__.py | 0
.../core/model/timerxl/configuration_timer.py | 0
.../ainode/core/model/timerxl/modeling_timer.py | 12 +-
.../core/model/timerxl/ts_generation_mixin.py | 0
.../{ => iotdb}/ainode/core/model/uri_utils.py | 10 +-
.../ainode/iotdb/ainode/core/rpc}/__init__.py | 0
.../ainode/{ => iotdb}/ainode/core/rpc/client.py | 65 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 137 ++
.../ainode/{ => iotdb}/ainode/core/rpc/service.py | 42 +-
.../ainode/{ => iotdb}/ainode/core/rpc/status.py | 6 +-
iotdb-core/ainode/iotdb/ainode/core/script.py | 69 +
.../ainode/iotdb/ainode/core/util}/__init__.py | 0
.../{ => iotdb}/ainode/core/util/activation.py | 0
.../ainode/iotdb/ainode/core/util/atmoic_int.py | 66 +
.../iotdb/ainode/core/util/batch_executor.py | 133 +
.../ainode/{ => iotdb}/ainode/core/util/cache.py | 4 +-
.../{ => iotdb}/ainode/core/util/decorator.py | 15 +
.../ainode/iotdb/ainode/core/util/gpu_mapping.py | 93 +
.../ainode/core/util/huggingface_cache.py | 0
.../ainode/{ => iotdb}/ainode/core/util/lock.py | 0
.../ainode/{ => iotdb}/ainode/core/util/masking.py | 0
.../ainode/{ => iotdb}/ainode/core/util/serde.py | 2 +-
.../pom.properties => core/util/thread_name.py} | 9 +-
.../ainode/iotdb/sqlalchemy/IoTDBSQLCompiler.py | 3 +-
iotdb-core/ainode/iotdb/table_session_pool.py | 2 +-
.../ainode/iotdb/template/MeasurementNode.py | 5 +-
iotdb-core/ainode/iotdb/template/Template.py | 2 +-
.../iotdb/thrift/ainode/IAINodeRPCService-remote | 6 +-
.../iotdb/thrift/ainode/IAINodeRPCService.py | 18 +-
iotdb-core/ainode/iotdb/thrift/ainode/constants.py | 11 +-
iotdb-core/ainode/iotdb/thrift/ainode/ttypes.py | 13 +-
iotdb-core/ainode/iotdb/thrift/common/constants.py | 11 +-
iotdb-core/ainode/iotdb/thrift/common/ttypes.py | 104 +-
.../thrift/confignode/IConfigNodeRPCService-remote | 70 +-
.../thrift/confignode/IConfigNodeRPCService.py | 1680 ++-----------
.../ainode/iotdb/thrift/confignode/constants.py | 11 +-
.../ainode/iotdb/thrift/confignode/ttypes.py | 2530 ++++++--------------
.../thrift/datanode/IDataNodeRPCService-remote | 31 +-
.../iotdb/thrift/datanode/IDataNodeRPCService.py | 567 +----
.../thrift/datanode/MPPDataExchangeService-remote | 6 +-
.../thrift/datanode/MPPDataExchangeService.py | 18 +-
.../ainode/iotdb/thrift/datanode/constants.py | 11 +-
iotdb-core/ainode/iotdb/thrift/datanode/ttypes.py | 319 +--
.../iotdb/thrift/rpc/IClientRPCService-remote | 13 +-
.../ainode/iotdb/thrift/rpc/IClientRPCService.py | 207 +-
iotdb-core/ainode/iotdb/thrift/rpc/constants.py | 11 +-
iotdb-core/ainode/iotdb/thrift/rpc/ttypes.py | 231 +-
.../iotdb/tsfile/utils/read_write_io_utils.py | 2 +-
.../ainode/iotdb/tsfile/utils/tsblock_serde.py | 1 -
iotdb-core/ainode/iotdb/utils/Field.py | 8 +-
iotdb-core/ainode/iotdb/utils/IoTDBConstants.py | 3 +-
iotdb-core/ainode/iotdb/utils/NumpyTablet.py | 4 +-
iotdb-core/ainode/iotdb/utils/SessionDataSet.py | 6 +-
iotdb-core/ainode/iotdb/utils/Tablet.py | 2 +-
iotdb-core/ainode/iotdb/utils/iotdb_rpc_dataset.py | 4 +-
iotdb-core/ainode/poetry.lock | 2402 -------------------
iotdb-core/ainode/pom.xml | 106 +-
iotdb-core/ainode/pyproject.toml | 109 +-
.../ainode/resources/syncPythonVersion.groovy | 33 -
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 20 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
.../async/AsyncAINodeHeartbeatClientPool.java | 7 +-
.../request/read/model/ShowModelPlan.java | 4 +-
.../consensus/response/model/GetModelInfoResp.java | 8 -
...eption.java => NoAvailableAINodeException.java} | 8 +-
.../iotdb/confignode/manager/ConfigManager.java | 49 +-
.../apache/iotdb/confignode/manager/IManager.java | 23 +-
.../iotdb/confignode/manager/ModelManager.java | 149 +-
.../iotdb/confignode/persistence/ModelInfo.java | 2 -
.../procedure/impl/model/CreateModelProcedure.java | 4 +-
.../procedure/impl/model/DropModelProcedure.java | 7 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 44 +-
.../db/protocol/client/AINodeClientFactory.java | 133 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 23 +-
.../db/protocol}/client/ainode/AINodeClient.java | 153 +-
.../client/ainode/AINodeClientManager.java | 75 +
.../client/ainode/AsyncAINodeServiceClient.java | 2 +-
.../table/v1/handler/ExecuteStatementHandler.java | 4 +
.../rest/v1/handler/ExecuteStatementHandler.java | 4 +
.../rest/v1/handler/QueryDataSetHandler.java | 4 +
.../rest/v2/handler/ExecuteStatementHandler.java | 4 +
.../rest/v2/handler/QueryDataSetHandler.java | 4 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 1 -
.../common/header/DatasetHeaderFactory.java | 8 +
.../operator/process/ai/InferenceOperator.java | 4 +-
.../InformationSchemaContentSupplierFactory.java | 17 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 8 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 10 +-
.../db/queryengine/plan/analyze/ModelFetcher.java | 23 +-
.../execution/config/TableConfigTaskVisitor.java | 32 +
.../execution/config/TreeConfigTaskVisitor.java | 33 +
.../config/executor/ClusterConfigTaskExecutor.java | 140 +-
.../config/executor/IConfigTaskExecutor.java | 8 +
.../{CreateModelTask.java => LoadModelTask.java} | 12 +-
.../ShowAIDevicesTask.java} | 38 +-
.../ShowLoadedModelsTask.java} | 41 +-
.../config/metadata/ai/ShowModelsTask.java | 4 +-
.../{CreateModelTask.java => UnloadModelTask.java} | 12 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 55 +
.../parameter/model/ModelInferenceDescriptor.java | 5 +-
.../function/tvf/ForecastTableFunction.java | 22 +-
.../plan/relational/sql/ast/AstVisitor.java | 16 +
.../sql/ast/{CreateModel.java => LoadModel.java} | 23 +-
.../ast/{NaturalJoin.java => ShowAIDevices.java} | 34 +-
.../{RemoveAINode.java => ShowLoadedModels.java} | 26 +-
.../sql/ast/{CreateModel.java => UnloadModel.java} | 22 +-
.../plan/relational/sql/parser/AstBuilder.java | 53 +
.../plan/statement/StatementVisitor.java | 20 +
...ModelStatement.java => LoadModelStatement.java} | 52 +-
.../ShowAIDevicesStatement.java} | 22 +-
.../model/ShowLoadedModelsStatement.java} | 45 +-
...delStatement.java => UnloadModelStatement.java} | 62 +-
.../db/queryengine/plan/udf/UDTFForecast.java | 270 +++
.../relational/analyzer/TableFunctionTest.java | 4 +-
iotdb-core/node-commons/pom.xml | 6 -
.../iotdb/commons/client/ClientPoolFactory.java | 52 -
.../commons/client/ainode/AINodeClientManager.java | 40 -
.../schema/column/ColumnHeaderConstant.java | 11 +
.../db/relational/grammar/sql/RelationalSql.g4 | 24 +
.../thrift-ainode/src/main/thrift/ainode.thrift | 32 +
.../src/main/thrift/confignode.thrift | 35 +-
scripts/conf/ainode-env.sh | 138 --
scripts/conf/windows/ainode-env.bat | 129 -
scripts/sbin/start-ainode.sh | 56 +-
scripts/sbin/windows/start-ainode.bat | 62 +-
193 files changed, 6921 insertions(+), 8543 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeConcurrentInferenceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeInstanceManagementIT.java
copy {iotdb-client/client-py => iotdb-core/ainode}/.flake8 (98%)
create mode 100644 iotdb-core/ainode/ainode.spec
delete mode 100644 iotdb-core/ainode/ainode/__init__.py
delete mode 100644
iotdb-core/ainode/ainode/core/inference/inference_request_pool.py
delete mode 100644 iotdb-core/ainode/ainode/core/rpc/handler.py
delete mode 100644 iotdb-core/ainode/ainode/core/script.py
create mode 100644 iotdb-core/ainode/build_binary.py
rename iotdb-core/ainode/{ainode/core => iotdb/ainode}/__init__.py (100%)
delete mode 100644 iotdb-core/ainode/iotdb/ainode/conf/git.properties
rename iotdb-core/ainode/{ainode/core/inference =>
iotdb/ainode/core}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/ai_node.py (87%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/config.py (81%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/constant.py (88%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/exception.py (96%)
rename iotdb-core/ainode/{ainode/core/inference/scheduler =>
iotdb/ainode/core/inference}/__init__.py (100%)
rename iotdb-core/ainode/{ainode/core/inference/strategy =>
iotdb/ainode/core/inference/batcher}/__init__.py (100%)
copy iotdb-client/client-py/iotdb/template/TemplateQueryType.py =>
iotdb-core/ainode/iotdb/ainode/core/inference/batcher/abstract_batcher.py (59%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/batcher/basic_batcher.py
rename iotdb-core/ainode/{ainode/core/ingress =>
iotdb/ainode/core/inference/dispatcher}/__init__.py (100%)
copy iotdb-core/ainode/iotdb/{template/TemplateNode.py =>
ainode/core/inference/dispatcher/abstract_dispatcher.py} (51%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/dispatcher/basic_dispatcher.py
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/inference_request.py (84%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/inference_request_pool.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/pool_controller.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/inference/pool_group.py
rename iotdb-core/ainode/{ainode/core/manager =>
iotdb/ainode/core/inference/pool_scheduler}/__init__.py (100%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/pool_scheduler/abstract_pool_scheduler.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/pool_scheduler/basic_pool_scheduler.py
rename iotdb-core/ainode/{ainode/core/model =>
iotdb/ainode/core/inference/request_scheduler}/__init__.py (100%)
rename
iotdb-core/ainode/{ainode/core/inference/scheduler/abstract_scheduler.py =>
iotdb/ainode/core/inference/request_scheduler/abstract_request_scheduler.py}
(98%)
rename iotdb-core/ainode/{ainode/core/inference/scheduler/basic_scheduler.py
=> iotdb/ainode/core/inference/request_scheduler/basic_request_scheduler.py}
(89%)
rename iotdb-core/ainode/{ainode/core/model/sundial =>
iotdb/ainode/core/inference/strategy}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/strategy/abstract_inference_pipeline.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/strategy/timer_sundial_inference_pipeline.py (88%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/strategy/timerxl_inference_pipeline.py (71%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/inference/utils.py (100%)
rename iotdb-core/ainode/{ainode/core/model/timerxl =>
iotdb/ainode/core/ingress}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/ingress/dataset.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/ingress/iotdb.py (95%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/log.py (96%)
rename iotdb-core/ainode/{ainode/core/rpc =>
iotdb/ainode/core/manager}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/cluster_manager.py
(88%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/inference_manager.py
(60%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/model_manager.py (82%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/utils.py (77%)
rename iotdb-core/ainode/{ainode/core/util =>
iotdb/ainode/core/model}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/built_in_model_factory.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_enums.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_factory.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_info.py (98%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_storage.py (93%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/sundial}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/sundial/configuration_sundial.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/sundial/flow_loss.py
(100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/sundial/modeling_sundial.py (97%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/sundial/ts_generation_mixin.py (100%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/timerxl}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/timerxl/configuration_timer.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/timerxl/modeling_timer.py (98%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/timerxl/ts_generation_mixin.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/uri_utils.py (94%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/rpc}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/rpc/client.py (80%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py
rename iotdb-core/ainode/{ => iotdb}/ainode/core/rpc/service.py (69%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/rpc/status.py (89%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/script.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/util}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/activation.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/atmoic_int.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/batch_executor.py
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/cache.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/decorator.py (79%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/gpu_mapping.py
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/huggingface_cache.py
(100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/lock.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/masking.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/serde.py (98%)
rename iotdb-core/ainode/iotdb/ainode/{conf/pom.properties =>
core/util/thread_name.py} (88%)
delete mode 100644 iotdb-core/ainode/poetry.lock
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/exception/{DatabaseNotExistsException.java
=> NoAvailableAINodeException.java} (79%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/AINodeClientFactory.java
rename iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons =>
datanode/src/main/java/org/apache/iotdb/db/protocol}/client/ainode/AINodeClient.java
(67%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/ainode/AINodeClientManager.java
rename iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons =>
datanode/src/main/java/org/apache/iotdb/db/protocol}/client/ainode/AsyncAINodeServiceClient.java
(98%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ai/{CreateModelTask.java
=> LoadModelTask.java} (82%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{ShowClusterIdTask.java
=> ai/ShowAIDevicesTask.java} (75%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{ShowAINodesTask.java
=> ai/ShowLoadedModelsTask.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ai/{CreateModelTask.java
=> UnloadModelTask.java} (82%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{CreateModel.java
=> LoadModel.java} (70%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{NaturalJoin.java
=> ShowAIDevices.java} (80%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{RemoveAINode.java
=> ShowLoadedModels.java} (70%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{CreateModel.java
=> UnloadModel.java} (73%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/{DropModelStatement.java
=> LoadModelStatement.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{ShowTTLStatement.java
=> model/ShowAIDevicesStatement.java} (74%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys/SetSqlDialectStatement.java
=> metadata/model/ShowLoadedModelsStatement.java} (65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/{CreateModelStatement.java
=> UnloadModelStatement.java} (62%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/udf/UDTFForecast.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClientManager.java
delete mode 100644 scripts/conf/ainode-env.sh
delete mode 100644 scripts/conf/windows/ainode-env.bat
