[iotdb] 03/03: Merge branch 'datanodeiter' into mlnode/test

[hui]

This is an automated email from the ASF dual-hosted git repository.

hui pushed a commit to branch mlnode/test
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit bb7bdb5356ab782c2cb55f9aecf9de5b9b74aa41
Merge: a996776c59 e7066f5f3a
Author: Minghui Liu <liuminghui...@foxmail.com>
AuthorDate: Fri Mar 31 11:26:09 2023 +0800

    Merge branch 'datanodeiter' into mlnode/test

 .../iotdb/commons/concurrent/ThreadName.java       |   3 +-
 .../apache/iotdb/commons/service/ServiceType.java  |   3 +-
 .../java/org/apache/iotdb/db/conf/IoTDBConfig.java |  22 +++
 .../org/apache/iotdb/db/conf/IoTDBDescriptor.java  |  13 ++
 .../db/mpp/plan/parser/StatementGenerator.java     |  69 +++++++
 .../java/org/apache/iotdb/db/service/DataNode.java |   4 +
 .../apache/iotdb/db/service/MLNodeRPCService.java  |  98 ++++++++++
 .../iotdb/db/service/MLNodeRPCServiceMBean.java    |  22 +++
 .../handler/MLNodeRPCServiceThriftHandler.java     |  56 ++++++
 .../impl/DataNodeInternalRPCServiceImpl.java       |  23 ---
 .../thrift/impl/IMLNodeRPCServiceWithHandler.java  |  26 +++
 .../service/thrift/impl/MLNodeRPCServiceImpl.java  | 206 +++++++++++++++++++++
 thrift-commons/src/main/thrift/common.thrift       |   6 -
 thrift/src/main/thrift/datanode.thrift             |  69 ++++---
 14 files changed, 563 insertions(+), 57 deletions(-)

diff --cc 
server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java
index 9e02350f5f,da32425582..d00903759a
--- 
a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java
@@@ -875,27 -870,10 +870,9 @@@ public class DataNodeInternalRPCService
  
    @Override
    public TSStatus deleteModelMetrics(TDeleteModelMetricsReq req) throws 
TException {
 -    // TODO
 -    throw new TException(new UnsupportedOperationException().getCause());
 +    return RpcUtils.SUCCESS_STATUS;
    }
  
-   @Override
-   public TFetchTimeseriesResp fetchTimeseries(TFetchTimeseriesReq req) throws 
TException {
-     // TODO
-     throw new TException(new UnsupportedOperationException().getCause());
-   }
- 
-   @Override
-   public TFetchWindowBatchResp fetchWindowBatch(TFetchWindowBatchReq req) 
throws TException {
-     // TODO
-     throw new TException(new UnsupportedOperationException().getCause());
-   }
- 
-   @Override
-   public TSStatus recordModelMetrics(TRecordModelMetricsReq req) throws 
TException {
-     // TODO
-     throw new TException(new UnsupportedOperationException().getCause());
-   }
- 
    private PathPatternTree filterPathPatternTree(PathPatternTree patternTree, 
String storageGroup) {
      PathPatternTree filteredPatternTree = new PathPatternTree();
      try {