This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/MLSQL
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from abf5d82de6 merge master
add 3ee95741cc [IoTDB-5637] Add substring as built-in scalar function
add 43d97732bb [IOTDB-5720] Fix release processor fail to release memory
due to writer-preferred starvation (#9431)
add 3264fdcf6a [IOTDB-5688] ShcemaFile mode lost template schema after
reboot in SimpleConsensus (#9432)
add db0a31cef8 [IOTDB-5717] Fix incorrect result when querying with limit
push-downing
add 1db187cd85 [IOTDB-5679] Implement model storage on MLNode (#9337)
add 872f524817 [IOTDB-5701] Fix typo in Performance Overview Related
Metrics (#9448)
add 11d7c6c685 update RELEASE_NOTES.md (#9450)
add aa46413528 Add user doc for function Replace
add f7e825bcca [IOTDB-5729] Fix RatisConsensus ResponseMessage conversion
error (#9452)
add ccbbfea676 [DOC] IoTDB cluster deploy tools (zh only) (#9447)
add c2870c6f34 [IOTDB-5696] Implement client to connect
ConfigNode/DataNode (#9365)
add 2862753172 [IOTDB-5693] Close child operator of MultiChildOperator
when the child operator is finished
add 6f90e11a5b Remove Dashboard and update docs (#9459)
add ff145c7cb4 [IOTDB-5730] Fix use a hard link when loading a SchemaFile
snapshot (#9460)
add f894ccdbdd [DOC] Add Apache header for IoTDB-Deploy.md (#9463)
add d0ad0defb0 [IOTDB-5731] Reconstructs the cli to support printing the
enterprise logo when connecting to the Enterprise Edition (#9462)
add 7f9c9ff29b [IOTDB-5732] Add Device Schema Statistics (#9466)
add f3b1e86e37 [IOTDB-5725] Make internal report recording measurements
asynchronous (#9439)
add 4087107755 [IOTDB-5722] Fix wrong default execution branch in
PlanVisitor (#9464)
add 960808fc40 [IOTDB-5121] Fix download link of library-udf (#9468)
add 1c77a2064a [IOTDB-5121] Fix download link of Library-UDF (#9471)
add 8ae4dbb187 [IOTDB-5714] Fix some IoTDB C++ SDK bugs (#9409)
add c723079e30 Catch NPE in CompactionSchedulerTest and print its stack
add 147a54303e [IOTDB-5687][REST Service] OpenAPI v2 interface (#9472)
add 94620929bb [IOTDB-5586] Reduce the scope of lock in MemoryPool Version2
add a7fe96937a [IOTDB-5738] Retain 2 copies of snapshot (#9474)
add af8f6afaad [IOTDB-5683] Add special case process for aggregation
function Mode
add 0fd9ebe7dc [IOTDB-5743] Fix: pipe plugin directory creates at the
shell running directory (#9482)
add 1bfcab297f [IOTDB-5678] Introduce machine learning algorithm libraries
on MLNode (#9338)
add f6f4728cfd [IOTDB-5680] Implement the basic data loader on MLNode
(#9372)
add 810bf11dfe [IOTDB-5675] Recover template activation statistics when
redoing MLog (#9483)
add 0750fa6f49 [IOTDB-5728] Implement config parser & model/dataset
factory on MLNode (#9458)
add c49e307114 [IOTDB-5373] Implement PipeSubTask and PipeExecutor (#9480)
add dadffb3814 [DOCS] remove invalid <br> tags in Aggregation.md (#9499)
add b42b533f7c Fix template type check on ClusterTemplateManager (#9494)
add 5505de1e87 Bump jackson-databind from 2.13.4.1 to 2.13.4.2 (#9497)
add 1df73ab327 feat(docs):site img move to alioss (#9505)
add ab88514f74 Update v1.1.0 download links (#9507)
add 5b3d89f362 [IOTDB-5709] [IOTDB-5658] [IoTDB ML] Implement
MLNodeInternalService on DataNode (#9398)
add fdec32eae7 Merge remote-tracking branch 'origin/master' into lmh/MLSQL
add 73be2cb3e4 modify iotdb server
No new revisions were added by this update.
Summary of changes:
RELEASE_NOTES.md | 73 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 10 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 17 +-
cli/src/main/java/org/apache/iotdb/cli/Cli.java | 2 +-
client-cpp/src/main/Session.cpp | 486 +-
client-cpp/src/main/Session.h | 114 +-
client-cpp/src/test/cpp/sessionIT.cpp | 220 +-
compile-tools/README.md | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 6 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 10 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 2 +
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 53 +-
docs/Download/README.md | 22 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 10 +-
docs/UserGuide/API/Programming-MQTT.md | 4 +-
.../UserGuide/API/Programming-Python-Native-API.md | 2 +-
.../API/{RestService.md => RestServiceV1.md} | 46 +-
.../API/{RestService.md => RestServiceV2.md} | 50 +-
docs/UserGuide/Cluster/Cluster-Concept.md | 4 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 2 +-
.../Data-Concept/Data-Model-and-Terminology.md | 4 +-
docs/UserGuide/Data-Concept/Schema-Template.md | 6 +-
docs/UserGuide/Data-Concept/Time-Partition.md | 2 +-
docs/UserGuide/Ecosystem-Integration/DBeaver.md | 16 +-
.../Ecosystem-Integration/Grafana-Connector.md | 6 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 58 +-
.../UserGuide/Ecosystem-Integration/Spark-IoTDB.md | 2 +-
.../Ecosystem-Integration/Spark-TsFile.md | 4 +-
.../Ecosystem-Integration/Writing-Data-on-HDFS.md | 2 +-
.../Ecosystem-Integration/Zeppelin-IoTDB.md | 8 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 2 +-
docs/UserGuide/IoTDB-Introduction/Architecture.md | 2 +-
docs/UserGuide/IoTDB-Introduction/Scenario.md | 14 +-
docs/UserGuide/Maintenance-Tools/JMX-Tool.md | 4 +-
docs/UserGuide/Maintenance-Tools/Log-Tool.md | 6 +-
docs/UserGuide/Monitor-Alert/Alerting.md | 2 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 4898 -----
.../Apache-IoTDB-DataNode-Dashboard.json | 20147 -------------------
.../Apache-IoTDB-Disk-IO-Dashboard.json | 894 -
.../Apache-IoTDB-Network-Dashboard.json | 533 -
...pache-IoTDB-Performance-Overview-Dashboard.json | 4350 ----
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 204 +-
.../Operate-Metadata/Auto-Create-MetaData.md | 2 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 2 +-
docs/UserGuide/Operators-Functions/Aggregation.md | 30 +-
docs/UserGuide/Operators-Functions/Conversion.md | 2 +-
docs/UserGuide/Operators-Functions/Sample.md | 6 +-
docs/UserGuide/Operators-Functions/String.md | 72 +-
.../Operators-Functions/User-Defined-Function.md | 10 +-
docs/UserGuide/Query-Data/Continuous-Query.md | 8 +-
docs/UserGuide/Query-Data/Group-By.md | 6 +-
docs/UserGuide/Query-Data/Overview.md | 2 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 24 +-
docs/UserGuide/Reference/TSDB-Comparison.md | 16 +-
docs/UserGuide/Write-Data/REST-API.md | 2 +-
docs/zh/Download/README.md | 22 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 10 +-
docs/zh/UserGuide/API/Programming-MQTT.md | 4 +-
.../UserGuide/API/Programming-Python-Native-API.md | 2 +-
.../API/{RestService.md => RestServiceV1.md} | 46 +-
.../API/{RestService.md => RestServiceV2.md} | 50 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 4 +-
docs/zh/UserGuide/Cluster/IoTDB-Deploy.md | 361 +
.../Data-Concept/Data-Model-and-Terminology.md | 4 +-
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 6 +-
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 2 +-
docs/zh/UserGuide/Ecosystem-Integration/DBeaver.md | 16 +-
.../Ecosystem-Integration/Grafana-Connector.md | 6 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 58 +-
.../UserGuide/Ecosystem-Integration/Workbench.md | 82 +-
.../Ecosystem-Integration/Writing-Data-on-HDFS.md | 2 +-
.../Ecosystem-Integration/Zeppelin-IoTDB.md | 8 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 2 +-
.../UserGuide/IoTDB-Introduction/Architecture.md | 2 +-
docs/zh/UserGuide/IoTDB-Introduction/Scenario.md | 14 +-
docs/zh/UserGuide/Maintenance-Tools/JMX-Tool.md | 4 +-
docs/zh/UserGuide/Maintenance-Tools/Log-Tool.md | 6 +-
docs/zh/UserGuide/Monitor-Alert/Alerting.md | 2 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 177 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 2 +-
.../UserGuide/Operators-Functions/Aggregation.md | 30 +-
.../zh/UserGuide/Operators-Functions/Conversion.md | 2 +-
docs/zh/UserGuide/Operators-Functions/Overview.md | 31 +-
docs/zh/UserGuide/Operators-Functions/Sample.md | 6 +-
docs/zh/UserGuide/Operators-Functions/String.md | 80 +-
.../Operators-Functions/User-Defined-Function.md | 2 +-
docs/zh/UserGuide/Query-Data/Continuous-Query.md | 8 +-
docs/zh/UserGuide/Query-Data/Group-By.md | 6 +-
docs/zh/UserGuide/Query-Data/Overview.md | 2 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 24 +-
docs/zh/UserGuide/Reference/TSDB-Comparison.md | 14 +-
docs/zh/UserGuide/Trigger/Implement-Trigger.md | 4 +-
docs/zh/UserGuide/Write-Data/REST-API.md | 2 +-
.../src/AlignedTimeseriesSessionExample.cpp | 8 +-
example/client-cpp-example/src/SessionExample.cpp | 9 +-
grafana-plugin/pkg/plugin/plugin.go | 8 +-
.../itbase/constant/BuiltinScalarFunctionEnum.java | 1 +
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 -
.../iotdb/db/it/aggregation/IoTDBModeIT.java | 24 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 108 +
.../scalar/IoTDBSubStringFunctionIT.java | 267 +
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 13 +
.../it/udf/IoTDBUDTFBuiltinScalarFunctionIT.java | 5 +-
.../iotdb/metrics/AbstractMetricService.java | 10 +-
mlnode/.gitignore | 6 +-
mlnode/iotdb/mlnode/client.py | 247 +-
mlnode/iotdb/mlnode/config.py | 27 +-
mlnode/iotdb/mlnode/constant.py | 2 +
mlnode/iotdb/mlnode/exception.py | 5 +
mlnode/iotdb/mlnode/model_storage.py | 95 +
mlnode/iotdb/mlnode/serde.py | 10 +-
mlnode/iotdb/mlnode/util.py | 1 -
mlnode/requirements.txt | 5 +
mlnode/requirements_dev.txt | 9 +-
mlnode/resources/conf/iotdb-mlnode.toml | 8 +
mlnode/test/test_model_storage.py | 78 +
mlnode/test/test_serde.py | 54 +-
.../resources/conf/iotdb-common.properties | 21 +-
.../iotdb/commons/concurrent/ThreadName.java | 8 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 8 +
.../iotdb/commons/model/ModelHyperparameter.java | 10 +
.../iotdb/commons/model/ModelInformation.java | 9 +-
.../iotdb/commons/model/TrailInformation.java | 7 +-
.../apache/iotdb/commons/service/ServiceType.java | 3 +-
.../metric/enums/PerformanceOverviewMetrics.java | 2 +-
.../commons/udf/builtin/BuiltinScalarFunction.java | 1 +
.../BuiltinTimeSeriesGeneratingFunction.java | 2 -
.../commons/udf/builtin/String/UDTFSubstr.java | 70 -
openapi/pom.xml | 56 +-
openapi/src/main/openapi3/iotdb_rest_common.yaml | 63 +
.../{iotdb-rest.yaml => iotdb_rest_v1.yaml} | 35 +-
.../{iotdb-rest.yaml => iotdb_rest_v2.yaml} | 35 +-
pom.xml | 2 +-
.../src/main/codegen/templates/ModeAccumulator.ftl | 49 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 35 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 22 +
.../org/apache/iotdb/db/constant/SqlConstant.java | 8 +
.../iotdb/db/engine/flush/MemTableFlushTask.java | 2 +-
.../runtime/MemoryLeakException.java} | 11 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 61 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 8 +-
.../db/metadata/mtree/store/MemMTreeStore.java | 2 +
.../mtree/store/StampedWriterPreferredLock.java | 21 +-
.../mtree/store/disk/cache/CacheMemoryManager.java | 116 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 2 +-
.../metadata/rescon/ISchemaRegionStatistics.java | 2 +
.../metadata/rescon/MemSchemaRegionStatistics.java | 15 +
.../schemaregion/SchemaRegionMemoryImpl.java | 37 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 148 +-
.../metadata/template/ClusterTemplateManager.java | 17 +
.../iotdb/db/mpp/common/FragmentInstanceId.java | 4 +
.../db/mpp/common/header/ColumnHeaderConstant.java | 8 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +-
.../execution/exchange/MPPDataExchangeManager.java | 6 +
.../mpp/execution/exchange/SharedTsBlockQueue.java | 12 +-
.../mpp/execution/exchange/sink/SinkChannel.java | 12 +-
.../execution/exchange/source/SourceHandle.java | 12 +-
.../fragment/FragmentInstanceExecution.java | 5 +
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 250 +-
.../process/AbstractConsumeAllOperator.java | 14 +-
.../operator/process/DeviceViewOperator.java | 7 +-
.../operator/process/MergeSortOperator.java | 6 +-
.../process/join/HorizontallyConcatOperator.java | 16 +-
.../process/join/RowBasedTimeJoinOperator.java | 8 +-
.../process/last/LastQueryCollectOperator.java | 6 +-
.../process/last/LastQueryMergeOperator.java | 25 +-
.../operator/process/last/LastQueryOperator.java | 7 +-
.../process/last/LastQuerySortOperator.java | 8 +-
.../operator/sink/ShuffleHelperOperator.java | 2 +-
.../execution/operator/source/SeriesScanUtil.java | 12 +-
.../config/metadata/model/ShowModelsTask.java | 51 +-
.../config/metadata/model/ShowTrailsTask.java | 29 +-
.../BuiltInScalarFunctionHelperFactory.java | 3 +
.../builtin/helper/SubStringFunctionHelper.java | 129 +
.../ConcatExpressionWithSuffixPathsVisitor.java | 3 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 29 +
.../db/mpp/plan/parser/StatementGenerator.java | 68 +
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 190 +-
.../scalar/SubStringFunctionColumnTransformer.java | 63 +
.../unary/scalar/SubStringFunctionTransformer.java | 63 +
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 15 +
.../PipeConnectorPluginRuntimeWrapper.java | 44 +-
.../PipeProcessorPluginRuntimeWrapper.java | 48 +-
.../executor/PipeAssignerSubtaskExecutor.java | 12 +-
.../executor/PipeConnectorSubtaskExecutor.java | 12 +-
.../executor/PipeProcessorSubtaskExecutor.java | 12 +-
.../execution/executor/PipeSubtaskExecutor.java | 122 +-
...kExecutor.java => PipeTaskExecutorManager.java} | 40 +-
.../scheduler/PipeAssignerSubtaskScheduler.java | 36 -
.../scheduler/PipeConnectorSubtaskScheduler.java | 36 -
.../scheduler/PipeProcessorSubtaskScheduler.java | 36 -
.../execution/scheduler/PipeSubtaskScheduler.java | 33 -
.../execution/scheduler/PipeTaskScheduler.java | 44 +-
.../org/apache/iotdb/db/pipe/task/PipeTask.java | 31 +-
.../DecoratingLock.java} | 26 +-
.../PipeAssignerSubtask.java | 6 +-
.../PipeConnectorSubtask.java | 13 +-
.../PipeProcessorSubtask.java | 13 +-
.../iotdb/db/pipe/task/callable/PipeSubtask.java | 135 +
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 20 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 20 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 20 +-
.../iotdb/db/pipe/task/stage/PipeTaskStage.java | 37 +-
.../rest/handler/AuthorizationHandler.java | 8 +-
.../rest/{ => v1}/handler/ExceptionHandler.java | 4 +-
.../{ => v1}/handler/ExecuteStatementHandler.java | 2 +-
.../rest/{ => v1}/handler/QueryDataSetHandler.java | 24 +-
.../{ => v1}/handler/RequestValidationHandler.java | 22 +-
.../handler/StatementConstructionHandler.java | 6 +-
.../rest/{ => v1}/impl/GrafanaApiServiceImpl.java | 25 +-
.../rest/{ => v1}/impl/RestApiServiceImpl.java | 20 +-
.../rest/{ => v2}/handler/ExceptionHandler.java | 2 +-
.../{ => v2}/handler/ExecuteStatementHandler.java | 2 +-
.../rest/{ => v2}/handler/QueryDataSetHandler.java | 26 +-
.../{ => v2}/handler/RequestValidationHandler.java | 8 +-
.../handler/StatementConstructionHandler.java | 4 +-
.../rest/{ => v2}/impl/GrafanaApiServiceImpl.java | 25 +-
.../rest/{ => v2}/impl/RestApiServiceImpl.java | 20 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +
.../apache/iotdb/db/service/MLNodeRPCService.java | 98 +
.../MLNodeRPCServiceMBean.java} | 4 +-
.../metrics/IoTDBInternalLocalReporter.java | 66 +-
.../handler/MLNodeRPCServiceThriftHandler.java | 56 +
.../service/thrift/impl/ClientRPCServiceImpl.java | 1 +
.../impl/DataNodeInternalRPCServiceImpl.java | 23 -
.../thrift/impl/IMLNodeRPCServiceWithHandler.java} | 8 +-
.../service/thrift/impl/MLNodeRPCServiceImpl.java | 206 +
.../engine/compaction/CompactionSchedulerTest.java | 3 +
.../mtree/lock/StampedWriterPreferredLockTest.java | 16 +-
.../schemaRegion/SchemaStatisticsTest.java | 31 +
.../db/mpp/execution/memory/MemoryPoolTest.java | 27 +-
.../operator/LastQueryMergeOperatorTest.java | 16 +-
.../execution/operator/MergeSortOperatorTest.java | 7 +-
.../executor/PipeAssignerSubtaskExecutorTest.java} | 20 +-
.../PipeConnectorSubtaskExecutorTest.java} | 24 +-
.../PipeProcessorSubtaskExecutorTest.java} | 24 +-
.../executor/PipeSubtaskExecutorTest.java | 158 +
.../series/SeriesScanLimitOffsetPushDownTest.java | 83 +-
site/iotdb-doap.rdf | 8 +
site/src/main/.vuepress/sidebar/V1.0.x/zh.ts | 1 +
site/src/main/.vuepress/sidebar/V1.1.x/en.ts | 3 +-
site/src/main/.vuepress/sidebar/V1.1.x/zh.ts | 4 +-
site/src/main/.vuepress/sidebar/en.ts | 3 +-
site/src/main/.vuepress/sidebar/zh.ts | 4 +-
thrift-commons/src/main/thrift/common.thrift | 6 -
thrift-mlnode/src/main/thrift/mlnode.thrift | 1 +
thrift/src/main/thrift/client.thrift | 5 +-
thrift/src/main/thrift/datanode.thrift | 69 +-
.../read/reader/series/PaginationController.java | 23 +
251 files changed, 5615 insertions(+), 32927 deletions(-)
copy docs/UserGuide/API/{RestService.md => RestServiceV1.md} (93%)
rename docs/UserGuide/API/{RestService.md => RestServiceV2.md} (94%)
delete mode 100644
docs/UserGuide/Monitor-Alert/Apache-IoTDB-ConfigNode-Dashboard.json
delete mode 100644
docs/UserGuide/Monitor-Alert/Apache-IoTDB-DataNode-Dashboard.json
delete mode 100644
docs/UserGuide/Monitor-Alert/Apache-IoTDB-Disk-IO-Dashboard.json
delete mode 100644
docs/UserGuide/Monitor-Alert/Apache-IoTDB-Network-Dashboard.json
delete mode 100644
docs/UserGuide/Monitor-Alert/Apache-IoTDB-Performance-Overview-Dashboard.json
copy docs/zh/UserGuide/API/{RestService.md => RestServiceV1.md} (94%)
rename docs/zh/UserGuide/API/{RestService.md => RestServiceV2.md} (94%)
create mode 100644 docs/zh/UserGuide/Cluster/IoTDB-Deploy.md
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/builtinfunction/scalar/IoTDBSubStringFunctionIT.java
create mode 100644 mlnode/iotdb/mlnode/model_storage.py
create mode 100644 mlnode/test/test_model_storage.py
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFSubstr.java
create mode 100644 openapi/src/main/openapi3/iotdb_rest_common.yaml
copy openapi/src/main/openapi3/{iotdb-rest.yaml => iotdb_rest_v1.yaml} (92%)
rename openapi/src/main/openapi3/{iotdb-rest.yaml => iotdb_rest_v2.yaml} (92%)
copy
server/src/main/java/org/apache/iotdb/db/{pipe/execution/executor/PipeProcessorSubtaskExecutor.java
=> exception/runtime/MemoryLeakException.java} (76%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/multi/builtin/helper/SubStringFunctionHelper.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/scalar/SubStringFunctionColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/unary/scalar/SubStringFunctionTransformer.java
rename
server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeTaskExecutor.java
=> PipeTaskExecutorManager.java} (59%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/execution/scheduler/PipeAssignerSubtaskScheduler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/execution/scheduler/PipeConnectorSubtaskScheduler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/execution/scheduler/PipeProcessorSubtaskScheduler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/execution/scheduler/PipeSubtaskScheduler.java
rename
server/src/main/java/org/apache/iotdb/db/pipe/task/{runnable/PipeSubtask.java
=> callable/DecoratingLock.java} (60%)
rename server/src/main/java/org/apache/iotdb/db/pipe/task/{runnable =>
callable}/PipeAssignerSubtask.java (89%)
rename server/src/main/java/org/apache/iotdb/db/pipe/task/{runnable =>
callable}/PipeConnectorSubtask.java (68%)
rename server/src/main/java/org/apache/iotdb/db/pipe/task/{runnable =>
callable}/PipeProcessorSubtask.java (68%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/task/callable/PipeSubtask.java
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v1}/handler/ExceptionHandler.java (97%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v1}/handler/ExecuteStatementHandler.java (97%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v1}/handler/QueryDataSetHandler.java (92%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v1}/handler/RequestValidationHandler.java (74%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v1}/handler/StatementConstructionHandler.java (97%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v1}/impl/GrafanaApiServiceImpl.java (92%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v1}/impl/RestApiServiceImpl.java (92%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v2}/handler/ExceptionHandler.java (98%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v2}/handler/ExecuteStatementHandler.java (97%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v2}/handler/QueryDataSetHandler.java (92%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v2}/handler/RequestValidationHandler.java (89%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v2}/handler/StatementConstructionHandler.java (98%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v2}/impl/GrafanaApiServiceImpl.java (92%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ =>
v2}/impl/RestApiServiceImpl.java (92%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/MLNodeRPCService.java
rename
server/src/main/java/org/apache/iotdb/db/{pipe/task/metrics/PipeTaskRuntimeRecorder.java
=> service/MLNodeRPCServiceMBean.java} (90%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/thrift/handler/MLNodeRPCServiceThriftHandler.java
copy
server/src/main/java/org/apache/iotdb/db/{pipe/execution/executor/PipeProcessorSubtaskExecutor.java
=> service/thrift/impl/IMLNodeRPCServiceWithHandler.java} (78%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/thrift/impl/MLNodeRPCServiceImpl.java
copy
server/src/{main/java/org/apache/iotdb/db/pipe/execution/executor/PipeAssignerSubtaskExecutor.java
=>
test/java/org/apache/iotdb/db/pipe/execution/executor/PipeAssignerSubtaskExecutorTest.java}
(63%)
copy
server/src/{main/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutor.java
=>
test/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutorTest.java}
(55%)
copy
server/src/{main/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutor.java
=>
test/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutorTest.java}
(55%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutorTest.java
