This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch table_disk_usage_statistics_with_cache
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3e3f6821c97 compact
new 6575e6edfe3 fix
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 dab572d24c6 The key cause by load snapshot failure is that nonclude
bytes involved preAlterColumn in these old snapshot data. Due to all data
involved tableNode are stored consecutively in the snapshot file. The content
of each element during serialization is of variable length, making it
impossible to identify the information of preAlteredColumn. So increment a
identify to find the position that can read preAlterColumn. (#17004)
add a524def3c6f Pipe: Fixed the NPE of tree privilege check (#17006)
add 8b81444db3e Improve DeviceViewIntoOperator's return style to pipeline
(#16994)
add 09db0d6b6de Release query resources in the Python sessionPool example
(#17013)
add 92308f2ba5a Only delete data, but don't delete tsfile when performing
a drop column statement on the table model (#16936)
add db973ea3217 [AINode] Fix call inference bug (#17011)
add 4ea03a5c448 fix: incorrect total row count when folding uncorrelated
scalar subquery (#17014)
add f71aabf60b6 [AINode] Integrate device manager framework (#16998)
add 337ac4799b7 Disable object type because it's too complex to release
(#17018)
add 3336d695e34 [AINode] Fix cannot be stopped by the stop script (#17020)
add 3567c245fd0 [AINode] Optimize build process (#17021)
add fe0d0f35c9d Fix OOM in SQL Parser ErrorHandler due to infinite loop in
ATN traversal (#17023)
add ae2793d5cdc Fix concurrent delete and flush error (#17026)
add 08a0f525cef Include the TSStatus code in Mqtt's error logs to
facilitate troubleshooting. (#17025)
add 623a9c3fe3a Pipe: Fixed the bug that privilege is not filtered for
real time events && Fixed the bug that the unclosed file may be degraded when
directly deleted && Fixed the skip-if problem of the write-back-sink && Fixed
the problem of tsFile privilege parsing (#17024)
add 178b5f8c5f5 Implement ExternalService Framework (#17009)
add 4afd2a0f016 Don't allow IntColumn DataType is DATE when query column
data of Date type used by Python client (#17015)
add 30eebf24d72 Print TableSchemaMap in TsFileSketchTool (#17031)
add 333b385a08a [AINode] Fix bugs and sync code (#17032)
add 607339cbeae fix: process tables for join scope (#17033)
add 78c1f492b60 Include the TSStatus code in Mqtt's error logs to
facilitate troubleshooting. (#17037)
new 8f2de96903e Merge branch 'iotdb_master' into
table_disk_usage_statistics_with_cache
new 991a1b6e842 record table size for when generating tsfile
The 3 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:
.gitignore | 3 +
.../iotdb/ainode/it/AINodeCallInferenceIT.java | 22 +
.../ainode/it/AINodeConcurrentForecastIT.java | 9 +-
...sterConfigIT.java => AINodeDeviceManageIT.java} | 72 ++-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 55 +--
.../treemodel/manual/IoTDBPipePermissionIT.java | 36 +-
.../pipe/it/single/IoTDBPipePermissionIT.java | 51 +++
.../relational/it/db/it/IoTDBDeletionTableIT.java | 158 +++++++
.../it/query/object/IoTDBObjectQuery2IT.java | 326 --------------
.../it/query/object/IoTDBObjectQueryIT.java | 309 -------------
.../it/query/old/IoTDBSimpleQueryTableIT.java | 63 +--
.../relational/it/query/recent/IoTDBCteIT.java | 31 +-
.../recent/informationschema/IoTDBServicesIT.java | 118 +++++
.../recent/subquery/SubqueryDataSetUtils.java | 4 +
.../IoTDBUncorrelatedScalarSubqueryIT.java | 5 +
.../view/recent/IoTDBTableViewAddColumnTest.java | 84 ++++
.../it/schema/IoTDBAlterColumnTypeIT.java | 1 +
.../relational/it/schema/IoTDBDatabaseIT.java | 12 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 141 ------
.../relational/it/session/IoTDBObjectDeleteIT.java | 363 ---------------
.../it/session/IoTDBObjectDeleteIT2.java | 48 --
.../relational/it/session/IoTDBObjectInsertIT.java | 339 --------------
.../it/session/IoTDBObjectInsertIT2.java | 170 -------
.../{external-api => external-service-api}/pom.xml | 10 +-
.../externalservice/api/IExternalService.java | 14 +-
iotdb-api/pom.xml | 1 +
.../src/test/cpp/sessionRelationalIT.cpp | 12 +-
iotdb-client/client-py/README.md | 2 +
.../client-py/iotdb/tsfile/utils/tsblock_serde.py | 4 +-
iotdb-client/client-py/session_example_date.py | 109 +++++
iotdb-client/client-py/session_pool_example.py | 18 +-
.../client-py/table_model_session_pool_example.py | 24 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 8 +
iotdb-core/ainode/build_binary.py | 54 ++-
iotdb-core/ainode/iotdb/ainode/core/ai_node.py | 11 +-
iotdb-core/ainode/iotdb/ainode/core/constant.py | 4 +-
.../ainode/iotdb/ainode/core/device}/__init__.py | 0
.../iotdb/ainode/core/device/backend}/__init__.py | 0
.../model_constants.py => device/backend/base.py} | 33 +-
.../ainode/core/device/backend/cpu_backend.py | 28 +-
.../backend/cuda_backend.py} | 30 +-
.../iotdb/ainode/core/device/device_utils.py | 58 +--
.../ainode/iotdb/ainode/core/device/env.py | 32 +-
.../ainode/core/inference/batcher/basic_batcher.py | 27 +-
.../ainode/core/inference/inference_request.py | 15 +-
.../core/inference/inference_request_pool.py | 33 +-
.../core/inference/pipeline/basic_pipeline.py | 11 +-
.../core/inference/pipeline/pipeline_loader.py | 4 +-
.../iotdb/ainode/core/inference/pool_controller.py | 88 ++--
.../pool_scheduler/abstract_pool_scheduler.py | 12 +-
.../pool_scheduler/basic_pool_scheduler.py | 50 +--
.../iotdb/ainode/core/manager/device_manager.py | 108 +++++
.../iotdb/ainode/core/manager/inference_manager.py | 66 ++-
.../ainode/iotdb/ainode/core/manager/utils.py | 34 +-
.../core/model/chronos2/pipeline_chronos2.py | 2 +-
.../ainode/iotdb/ainode/core/model/model_loader.py | 14 +-
.../ainode/core/model/sktime/pipeline_sktime.py | 2 +-
.../ainode/core/model/sundial/pipeline_sundial.py | 2 +-
.../ainode/core/model/timer_xl/pipeline_timer.py | 2 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 62 ++-
iotdb-core/ainode/iotdb/ainode/core/rpc/service.py | 2 +-
.../ainode/iotdb/ainode/core/util/gpu_mapping.py | 93 ----
iotdb-core/ainode/pom.xml | 34 --
iotdb-core/ainode/pyproject.toml | 6 +-
.../ainode/resources/conf/iotdb-ainode.properties | 2 +-
.../ainode/resources/syncPythonVersion.groovy | 159 -------
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 3 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 24 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 13 +
.../client/async/CnToDnAsyncRequestType.java | 3 +
.../CnToDnInternalServiceAsyncRequestManager.java | 5 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 9 +
...va => GetBuiltInExternalServiceRPCHandler.java} | 25 +-
.../confignode/conf/SystemPropertiesUtils.java | 15 -
.../consensus/request/ConfigPhysicalPlan.java | 16 +
.../consensus/request/ConfigPhysicalPlanType.java | 6 +
.../ShowExternalServicePlan.java} | 28 +-
.../CreateExternalServicePlan.java} | 40 +-
.../DropExternalServicePlan.java} | 39 +-
.../StartExternalServicePlan.java} | 39 +-
.../StopExternalServicePlan.java} | 39 +-
.../externalservice/ShowExternalServiceResp.java | 53 +++
.../iotdb/confignode/manager/ConfigManager.java | 64 +++
.../apache/iotdb/confignode/manager/IManager.java | 15 +
.../externalservice/ExternalServiceInfo.java | 312 +++++++++++++
.../externalservice/ExternalServiceManager.java | 215 +++++++++
.../iotdb/confignode/manager/node/NodeManager.java | 13 +-
.../persistence/executor/ConfigPlanExecutor.java | 22 +
.../confignode/persistence/schema/ConfigMTree.java | 37 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 27 ++
.../persistence/ExternalServiceInfoTest.java | 93 ++++
.../persistence/schema/ConfigMTreeTest.java | 58 +++
.../test/resources/oldsnapshot/cluster_schema.bin | Bin 0 -> 121 bytes
.../resources/oldsnapshot/table_cluster_schema.bin | Bin 0 -> 5177 bytes
iotdb-core/datanode/pom.xml | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 9 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 9 -
.../ChunkTypeInconsistentException.java} | 30 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 3 +-
.../subtask/processor/PipeProcessorSubtask.java | 21 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 4 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 -
.../scan/TsFileInsertionEventScanParser.java | 3 +-
.../table/TsFileInsertionEventTableParser.java | 16 +-
.../pipeconsensus/PipeConsensusReceiver.java | 2 +-
.../sink/protocol/writeback/WriteBackSink.java | 14 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 35 ++
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 14 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 20 +-
.../common/header/DatasetHeaderFactory.java | 4 +
.../execution/fragment/QueryStatistics.java | 10 +-
.../operator/process/AbstractIntoOperator.java | 6 +-
.../operator/process/AbstractTreeIntoOperator.java | 8 +-
.../operator/process/DeviceViewIntoOperator.java | 110 ++++-
.../process/InsertTabletStatementGenerator.java | 4 +
.../operator/process/TableIntoOperator.java | 5 +
.../operator/process/TreeIntoOperator.java | 37 +-
.../execution/operator/source/FileLoaderUtils.java | 12 +-
.../execution/operator/source/SeriesScanUtil.java | 40 +-
.../InformationSchemaContentSupplierFactory.java | 37 ++
.../relational/ColumnTransformerBuilder.java | 36 --
.../iotdb/db/queryengine/plan/Coordinator.java | 8 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 21 +-
.../queryengine/plan/analyze/SelectIntoUtils.java | 42 +-
.../execution/config/TableConfigTaskVisitor.java | 40 ++
.../execution/config/TreeConfigTaskVisitor.java | 41 ++
.../config/executor/ClusterConfigTaskExecutor.java | 114 +++++
.../config/executor/IConfigTaskExecutor.java | 10 +
.../config/metadata/ai/ShowAIDevicesTask.java | 15 +-
.../CreateExternalServiceTask.java} | 32 +-
.../DropExternalServiceTask.java} | 18 +-
.../ShowExternalServiceTask.java} | 44 +-
.../StartExternalServiceTask.java} | 14 +-
.../StopExternalServiceTask.java} | 14 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 34 ++
.../parameter/DeviceViewIntoPathDescriptor.java | 5 +-
.../planner/plan/parameter/IntoPathDescriptor.java | 5 +-
.../plan/relational/analyzer/Scope.java | 3 +-
.../relational/analyzer/StatementAnalyzer.java | 18 +-
.../function/tvf/ClassifyTableFunction.java | 2 +-
.../function/tvf/ForecastTableFunction.java | 2 +-
.../relational/metadata/TableMetadataImpl.java | 18 -
.../fetcher/TableDeviceSchemaValidator.java | 13 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 61 +--
.../DataNodeLocationSupplierFactory.java | 1 +
.../security/TreeAccessCheckVisitor.java | 42 ++
.../plan/relational/sql/ast/AstVisitor.java | 20 +
.../{ShowIndex.java => CreateExternalService.java} | 41 +-
.../{ShowIndex.java => DropExternalService.java} | 35 +-
...riesStatement.java => ShowExternalService.java} | 6 +-
...DropFunction.java => StartExternalService.java} | 26 +-
...{DropFunction.java => StopExternalService.java} | 26 +-
.../plan/relational/sql/parser/AstBuilder.java | 44 ++
.../plan/relational/sql/parser/ErrorHandler.java | 31 +-
.../plan/relational/sql/rewrite/ShowRewrite.java | 15 +
.../plan/relational/sql/util/AstUtil.java | 30 --
.../scheduler/load/LoadTsFileDispatcherImpl.java | 4 +-
.../queryengine/plan/statement/StatementType.java | 7 +
.../plan/statement/StatementVisitor.java | 31 ++
.../CreateExternalServiceStatement.java} | 35 +-
.../DropExternalServiceStatement.java} | 34 +-
.../ShowExternalServiceStatement.java} | 32 +-
.../StartExternalServiceStatement.java} | 29 +-
.../StopExternalServiceStatement.java} | 29 +-
.../db/queryengine/plan/udf/UDTFForecast.java | 3 +-
.../FragmentInstanceStatisticsDrawer.java | 6 +
.../binary/ReadObject2ColumnTransformer.java | 78 ----
.../ternary/ReadObject3ColumnTransformer.java | 99 -----
.../unary/scalar/ReadObjectColumnTransformer.java | 126 ------
.../schemaregion/utils/ResourceByPathUtils.java | 29 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 30 ++
.../db/service/ResourcesInformationHolder.java | 11 +
.../externalservice/BuiltinExternalServices.java | 57 +++
.../ExternalServiceClassLoader.java} | 10 +-
.../ExternalServiceManagementException.java} | 11 +-
.../ExternalServiceManagementService.java | 379 ++++++++++++++++
.../storageengine/dataregion/Base32ObjectPath.java | 169 -------
.../db/storageengine/dataregion/DataRegion.java | 35 +-
.../db/storageengine/dataregion/IObjectPath.java | 9 +-
.../storageengine/dataregion/PlainObjectPath.java | 126 ------
.../performer/impl/FastCompactionPerformer.java | 7 +-
.../impl/ReadChunkCompactionPerformer.java | 2 +
.../impl/ReadPointCompactionPerformer.java | 1 +
.../execute/task/AbstractCompactionTask.java | 13 +
.../execute/task/CompactionTaskSummary.java | 15 +
.../execute/task/CrossSpaceCompactionTask.java | 19 +
.../execute/task/InnerSpaceCompactionTask.java | 26 +-
.../task/InsertionCrossSpaceCompactionTask.java | 4 +
.../FastNonAlignedSeriesCompactionExecutor.java | 11 +
.../readchunk/SingleSeriesCompactionExecutor.java | 8 +
.../utils/writer/AbstractCompactionWriter.java | 7 +
.../writer/AbstractCrossCompactionWriter.java | 3 +
.../writer/AbstractInnerCompactionWriter.java | 4 +
.../dataregion/memtable/TsFileProcessor.java | 6 +
.../dataregion/modification/DeletionPredicate.java | 4 +
.../read/reader/chunk/DiskChunkLoader.java | 7 +
.../dataregion/tsfile/TsFileResource.java | 6 +-
.../tableDiskUsageCache/TableDiskUsageCache.java | 5 +-
.../TableDiskUsageCacheReader.java | 5 +-
.../TableDiskUsageCacheWriter.java | 2 +-
.../TsFileTableSizeCacheReader.java | 11 +-
.../db/storageengine/load/LoadTsFileManager.java | 7 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 5 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 30 ++
.../org/apache/iotdb/db/utils/ObjectTypeUtils.java | 26 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 297 ++++++++-----
.../org/apache/iotdb/db/utils/TabletDecoder.java | 2 +-
.../db/pipe/pattern/IoTDBTreePatternTest.java | 1 +
.../operator/DeviceViewIntoOperatorTest.java | 487 +++++++++++++++++++++
.../execution/operator/TreeIntoOperatorTest.java | 303 +++++++++++++
.../plan/function/RecordObjectTypeTest.java | 156 -------
.../plan/relational/planner/CteSubqueryTest.java | 2 -
.../sql/ast/SqlParserErrorHandlerTest.java | 76 ++++
.../unary/scalar/ObjectTypeFunctionTest.java | 186 --------
.../DataNodeInternalRPCServiceImplTest.java | 3 +-
.../object/ObjectTypeCompactionTest.java | 459 -------------------
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 149 ++++++-
iotdb-core/node-commons/pom.xml | 5 +
.../conf/iotdb-system.properties.template | 10 -
.../iotdb/commons/conf/CommonDescriptor.java | 5 -
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../iotdb/commons/externalservice/ServiceInfo.java | 170 +++++++
.../datastructure/pattern/IoTDBTreePattern.java | 7 +-
.../schema/column/ColumnHeaderConstant.java | 18 +-
.../commons/schema/table/InformationSchema.java | 11 +
.../apache/iotdb/commons/schema/table/TsTable.java | 43 +-
.../relational/TableBuiltinScalarFunction.java | 1 -
.../db/relational/grammar/sql/RelationalSql.g4 | 35 +-
.../thrift-ainode/src/main/thrift/ainode.thrift | 4 +-
.../thrift-commons/src/main/thrift/common.thrift | 14 +
.../src/main/thrift/confignode.thrift | 23 +
.../src/main/thrift/datanode.thrift | 7 +
pom.xml | 2 +-
233 files changed, 5597 insertions(+), 4795 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/ainode/it/{AINodeClusterConfigIT.java
=> AINodeDeviceManageIT.java} (55%)
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/object/IoTDBObjectQuery2IT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/object/IoTDBObjectQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/informationschema/IoTDBServicesIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBTableViewAddColumnTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/IoTDBObjectDeleteIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/IoTDBObjectDeleteIT2.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/IoTDBObjectInsertIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/IoTDBObjectInsertIT2.java
copy iotdb-api/{external-api => external-service-api}/pom.xml (90%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTask.java
=>
iotdb-api/external-service-api/src/main/java/org/apache/iotdb/externalservice/api/IExternalService.java
(72%)
create mode 100644 iotdb-client/client-py/session_example_date.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/device}/__init__.py (100%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/device/backend}/__init__.py (100%)
copy iotdb-core/ainode/iotdb/ainode/core/{model/model_constants.py =>
device/backend/base.py} (59%)
copy iotdb-client/client-py/iotdb/tsfile/common/constant/tsfile_constant.py =>
iotdb-core/ainode/iotdb/ainode/core/device/backend/cpu_backend.py (65%)
copy iotdb-core/ainode/iotdb/ainode/core/{util/decorator.py =>
device/backend/cuda_backend.py} (57%)
copy iotdb-client/client-py/iotdb/dbapi/Exceptions.py =>
iotdb-core/ainode/iotdb/ainode/core/device/device_utils.py (51%)
copy iotdb-client/client-py/iotdb/template/TemplateQueryType.py =>
iotdb-core/ainode/iotdb/ainode/core/device/env.py (59%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/manager/device_manager.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/gpu_mapping.py
delete mode 100644 iotdb-core/ainode/resources/syncPythonVersion.groovy
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{PipePushMetaRPCHandler.java
=> GetBuiltInExternalServiceRPCHandler.java} (75%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{trigger/GetTriggerJarPlan.java
=> exernalservice/ShowExternalServicePlan.java} (65%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{function/DropTreeModelFunctionPlan.java
=> externalservice/CreateExternalServicePlan.java} (61%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{trigger/DeleteTriggerInTablePlan.java
=> externalservice/DropExternalServicePlan.java} (61%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{trigger/DeleteTriggerInTablePlan.java
=> externalservice/StartExternalServicePlan.java} (61%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{trigger/DeleteTriggerInTablePlan.java
=> externalservice/StopExternalServicePlan.java} (61%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/externalservice/ShowExternalServiceResp.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/externalservice/ExternalServiceInfo.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/externalservice/ExternalServiceManager.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/ExternalServiceInfoTest.java
create mode 100644
iotdb-core/confignode/src/test/resources/oldsnapshot/cluster_schema.bin
create mode 100644
iotdb-core/confignode/src/test/resources/oldsnapshot/table_cluster_schema.bin
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/compaction/selector/utils/DeviceInfo.java
=> exception/ChunkTypeInconsistentException.java} (58%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{CreatePipePluginTask.java
=> externalservice/CreateExternalServiceTask.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{ai/LoadModelTask.java
=> externalservice/DropExternalServiceTask.java} (75%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{region/ExtendRegionTask.java
=> externalservice/ShowExternalServiceTask.java} (56%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{ai/DropModelTask.java
=> externalservice/StartExternalServiceTask.java} (79%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{ai/DropModelTask.java
=> externalservice/StopExternalServiceTask.java} (80%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowIndex.java
=> CreateExternalService.java} (63%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowIndex.java
=> DropExternalService.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowQueriesStatement.java
=> ShowExternalService.java} (89%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DropFunction.java
=> StartExternalService.java} (72%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DropFunction.java
=> StopExternalService.java} (72%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{CreateFunctionStatement.java
=> externalservice/CreateExternalServiceStatement.java} (69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{template/DropSchemaTemplateStatement.java
=> externalservice/DropExternalServiceStatement.java} (67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{region/ExtendRegionStatement.java
=> externalservice/ShowExternalServiceStatement.java} (69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{template/DropSchemaTemplateStatement.java
=> externalservice/StartExternalServiceStatement.java} (72%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{template/DropSchemaTemplateStatement.java
=> externalservice/StopExternalServiceStatement.java} (72%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/binary/ReadObject2ColumnTransformer.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/ternary/ReadObject3ColumnTransformer.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReadObjectColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/externalservice/BuiltinExternalServices.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{trigger/service/TriggerClassLoader.java
=> service/externalservice/ExternalServiceClassLoader.java} (82%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/analyze/IModelFetcher.java
=> service/externalservice/ExternalServiceManagementException.java} (75%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/externalservice/ExternalServiceManagementService.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/Base32ObjectPath.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/PlainObjectPath.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/DeviceViewIntoOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/TreeIntoOperatorTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/function/RecordObjectTypeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/SqlParserErrorHandlerTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ObjectTypeFunctionTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/object/ObjectTypeCompactionTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/externalservice/ServiceInfo.java
