This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch force_ci/alter_column_datatype
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 22e99f1e681 Merge branch 'master' into force_ci/alter_column_datatype
add 598080b47f7 Fixed the show regions with specified database & grant /
revoke with ""
add 33d5b195fb0 Support Training Module of AINode
add 242db7672c7 Update Cli -help information (#15159)
add c520c39ff2f use getter for_encryptParam and change tsfile version
(#15185)
add 5f635bf464e DAL: Remove dal file after drop databases or remove
dataRegions (#15191)
add 299c3df372c Improve ConfigNode removing #15189
add a5c1d117ea5 Load: Added the missing permission check for auto-create
database in loading tsFile (#15190)
add 0f0aaf410da Pipe: Fixed the authority for table model insertion
(#15186)
add 77b7541eb7e Fix incorrect os dirs creation (#15196)
add 91fb32a5c3a Pipe: Added default logic for username / password in tree
sql-dialect pipes & Fixed the NPE for configNode table schema snapshot parsing
need (#15200)
add e86ec17bc95 Pipe: Add metrics for tsfile to tablets invocation call
count and time (#15202)
add c986324b0e6 Pipe: Enable showing WRITE_BACK_SINK (#15207)
add 3805b47e58b remove export tsfile script (#15206)
add e62bbf52833 Pipe: Enable showing WRITE_BACK_SINK (Fix IoTDBDatabaseIT)
(#15209)
add a81c5c6ac70 Load: Support multi-disks awareness for IoTV2 and Pipe
(#15181)
add 7fe614c7cc2 Pipe: Added close for tree session in WriteBackConnector
(#15211)
add 7bfcb4965c1 fix: clone & delete issues (#15153)
add 4678776f5c1 Pipe Plugin: Fix ClassLoader and Visibility not
initialized from CN snapshot after reboot (#15212)
add f66fcd91642 Pipe: Fixed the NPE of OPC UA Sink in table model when
there are null values & Deleted the extra folder of opc ua sink in table model
(#15215)
add ebb1bcf8910 Load: Add default value for multi disks awareness (#15216)
add 3d1cd0ea7f6 Pipe: Fix the problem of missing points in TsFile of
parsing table model (#15217)
add e6e392c8a47 Merge branch 'master' into force_ci/alter_column_datatype
No new revisions were added by this update.
Summary of changes:
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 42 ++++
.../manual/basic/IoTDBPipePermissionIT.java | 90 ++++++++-
.../it/db/it/IoTDBAuthenticationTableIT.java | 90 ++++-----
.../relational/it/db/it/IoTDBInsertTableIT.java | 39 ++++
.../relational/it/schema/IoTDBDatabaseIT.java | 10 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 4 +-
.../cli/src/assembly/resources/sbin/start-cli.sh | 4 -
.../src/assembly/resources/tools/export-tsfile.bat | 62 ------
.../src/assembly/resources/tools/export-tsfile.sh | 59 ------
.../java/org/apache/iotdb/cli/AbstractCli.java | 33 ++--
.../apache/iotdb/tool/data/ImportDataTable.java | 7 +-
iotdb-client/client-py/resources/pyproject.toml | 2 +-
iotdb-core/ainode/.gitignore | 4 +-
iotdb-core/ainode/{iotdb => ainode}/__init__.py | 0
.../{iotdb/ainode => ainode/core}/__init__.py | 0
.../ainode/{iotdb/ainode => ainode/core}/client.py | 42 +++-
.../ainode/{iotdb/ainode => ainode/core}/config.py | 22 +--
.../{iotdb/ainode => ainode/core}/constant.py | 0
.../{iotdb/ainode => ainode/core}/exception.py | 2 +-
.../{iotdb/ainode => ainode/core}/handler.py | 19 +-
.../ainode/{iotdb/ainode => ainode/core}/log.py | 4 +-
.../ainode => ainode/core}/manager/__init__.py | 0
.../core}/manager/cluster_manager.py | 4 +-
.../core}/manager/inference_manager.py | 14 +-
.../core}/manager/model_manager.py | 16 +-
.../ainode => ainode/core}/model/__init__.py | 0
.../core}/model/built_in_model_factory.py | 8 +-
.../ainode => ainode/core}/model/model_factory.py | 10 +-
.../ainode => ainode/core}/model/model_storage.py | 15 +-
.../ainode/{iotdb/ainode => ainode/core}/script.py | 16 +-
.../{iotdb/ainode => ainode/core}/service.py | 8 +-
.../{iotdb/ainode => ainode/core}/util/__init__.py | 0
.../ainode => ainode/core}/util/decorator.py | 0
.../{iotdb/ainode => ainode/core}/util/lock.py | 0
.../{iotdb/ainode => ainode/core}/util/serde.py | 6 +-
.../{iotdb/ainode => ainode/core}/util/status.py | 6 +-
iotdb-core/ainode/pom.xml | 8 +-
iotdb-core/ainode/pyproject.toml | 21 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 13 ++
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 13 +-
.../request/write/model/UpdateModelInfoPlan.java | 4 +
.../iotdb/confignode/manager/ConfigManager.java | 121 +++++++++++-
.../iotdb/confignode/manager/ModelManager.java | 51 ++++-
.../confignode/manager/PermissionManager.java | 2 +
.../manager/load/service/StatisticsService.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 27 ++-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 11 +-
.../persistence/executor/ConfigPlanExecutor.java | 10 +-
.../confignode/persistence/node/NodeInfo.java | 7 +
.../persistence/pipe/PipePluginInfo.java | 51 ++++-
.../thrift/ConfigNodeRPCServiceProcessor.java | 17 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 23 +++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 17 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 11 +-
.../connector/protocol/opcua/OpcUaNameSpace.java | 11 +-
.../protocol/writeback/WriteBackConnector.java | 3 +
.../deletion/DeletionResourceManager.java | 6 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 2 +
.../tsfile/parser/TsFileInsertionEventParser.java | 21 ++
.../parser/TsFileInsertionEventParserProvider.java | 61 +++++-
.../query/TsFileInsertionEventQueryParser.java | 19 +-
.../scan/TsFileInsertionEventScanParser.java | 15 +-
.../table/TsFileInsertionEventTableParser.java | 16 +-
...ileInsertionEventTableParserTabletIterator.java | 20 +-
.../dataregion/IoTDBDataRegionExtractor.java | 2 +
.../iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 3 +
.../overview/PipeTsFileToTabletsMetrics.java | 170 ++++++++++++++++
.../protocol/thrift/IoTDBDataNodeReceiver.java | 55 +++---
.../visitor/PipeStatementExceptionVisitor.java | 5 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 14 ++
.../iotdb/db/queryengine/plan/Coordinator.java | 4 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 5 +-
.../execution/config/TableConfigTaskVisitor.java | 46 ++++-
.../execution/config/TreeConfigTaskVisitor.java | 44 ++++-
.../config/executor/ClusterConfigTaskExecutor.java | 52 ++++-
.../config/executor/IConfigTaskExecutor.java | 27 ++-
.../metadata/{model => ai}/CreateModelTask.java | 2 +-
.../config/metadata/ai/CreateTrainingTask.java | 108 +++++++++++
.../metadata/{model => ai}/DropModelTask.java | 2 +-
.../metadata/{model => ai}/ShowModelsTask.java | 2 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 66 +++++--
.../plan/relational/sql/ast/AstVisitor.java | 8 +
.../plan/relational/sql/ast/CreateTraining.java | 156 +++++++++++++++
.../ast/{ShowConfigNodes.java => ShowModels.java} | 34 ++--
.../plan/relational/sql/ast/ShowRegions.java | 43 ++---
.../plan/relational/sql/parser/AstBuilder.java | 139 ++++++++++---
.../plan/statement/StatementVisitor.java | 5 +
.../statement/metadata/ShowRegionStatement.java | 29 +--
.../metadata/model/CreateTrainingStatement.java | 140 ++++++++++++++
.../iotdb/db/storageengine/StorageEngine.java | 1 +
.../db/storageengine/dataregion/DataRegion.java | 70 ++++++-
.../memtable/AlignedWritableMemChunk.java | 214 ++++++++++-----------
...ertedInsertTabletStatementExceptionVisitor.java | 5 +
.../storageengine/load/disk/ILoadDiskSelector.java | 66 +++++++
.../InheritSystemMultiDisksStrategySelector.java | 58 ++++++
.../db/storageengine/load/disk/MinIOSelector.java | 112 +++++++++++
.../db/storageengine/rescon/disk/TierManager.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 47 +++--
.../iotdb/db/utils/datastructure/TVList.java | 5 +-
.../apache/iotdb/metrics/utils/FileStoreUtils.java | 2 +-
.../conf/iotdb-system.properties.template | 21 ++
.../iotdb/commons/client/ainode/AINodeClient.java | 13 ++
.../iotdb/commons/model/ModelInformation.java | 20 ++
.../apache/iotdb/commons/model/ModelStatus.java | 1 +
.../agent/plugin/builtin/BuiltinPipePlugin.java | 1 -
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 56 +++++-
.../thrift-ainode/src/main/thrift/ainode.thrift | 16 ++
.../src/main/thrift/confignode.thrift | 35 ++++
pom.xml | 2 +-
112 files changed, 2479 insertions(+), 660 deletions(-)
delete mode 100644
iotdb-client/cli/src/assembly/resources/tools/export-tsfile.bat
delete mode 100644
iotdb-client/cli/src/assembly/resources/tools/export-tsfile.sh
rename iotdb-core/ainode/{iotdb => ainode}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/client.py (81%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/config.py (91%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/constant.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/exception.py (98%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/handler.py (69%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/log.py (97%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/manager/__init__.py
(100%)
rename iotdb-core/ainode/{iotdb/ainode =>
ainode/core}/manager/cluster_manager.py (93%)
rename iotdb-core/ainode/{iotdb/ainode =>
ainode/core}/manager/inference_manager.py (95%)
rename iotdb-core/ainode/{iotdb/ainode =>
ainode/core}/manager/model_manager.py (86%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/model/__init__.py (100%)
rename iotdb-core/ainode/{iotdb/ainode =>
ainode/core}/model/built_in_model_factory.py (99%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/model/model_factory.py
(96%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/model/model_storage.py
(92%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/script.py (93%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/service.py (91%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/util/__init__.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/util/decorator.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/util/lock.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/util/serde.py (98%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/util/status.py (90%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeTsFileToTabletsMetrics.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{model
=> ai}/CreateModelTask.java (99%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ai/CreateTrainingTask.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{model
=> ai}/DropModelTask.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{model
=> ai}/ShowModelsTask.java (99%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreateTraining.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowConfigNodes.java
=> ShowModels.java} (72%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateTrainingStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/disk/ILoadDiskSelector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/disk/InheritSystemMultiDisksStrategySelector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/disk/MinIOSelector.java
