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

caogaofei pushed a commit to branch beyyes/dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/beyyes/dev/1.3 by this push:
     new c71af66f03c fix api
c71af66f03c is described below

commit c71af66f03c85e6d974a870145ea2fcc96bf6be4
Author: Beyyes <[email protected]>
AuthorDate: Thu Mar 20 14:00:01 2025 +0800

    fix api
---
 .../protocol/thrift/impl/ClientRPCServiceImpl.java | 28 ++--------------------
 1 file changed, 2 insertions(+), 26 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java
index bfd440bd319..a248002c390 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java
@@ -1039,7 +1039,8 @@ public class ClientRPCServiceImpl implements 
IClientRPCServiceWithHandler {
     return executeAggregationQueryInternal(req, SELECT_RESULT);
   }
 
-  public TSExecuteStatementResp 
executeGroupByQueryIntervalQuery2(TSGroupByQueryIntervalReq req)
+  @Override
+  public TSExecuteStatementResp 
executeGroupByQueryIntervalQuery(TSGroupByQueryIntervalReq req)
       throws TException {
 
     try {
@@ -1104,31 +1105,6 @@ public class ClientRPCServiceImpl implements 
IClientRPCServiceWithHandler {
     }
   }
 
-  @Override
-  public TSExecuteStatementResp 
executeGroupByQueryIntervalQuery(TSGroupByQueryIntervalReq req)
-      throws TException {
-    try {
-      TSDataType dataType = TSDataType.getTsDataType((byte) req.getDataType());
-      List<TsBlock> blockResult = Collections.emptyList();
-      String outputColumnName = req.getAggregationType().name();
-      List<ColumnHeader> columnHeaders =
-          Collections.singletonList(new ColumnHeader(outputColumnName, 
dataType));
-      DatasetHeader header = new DatasetHeader(columnHeaders, false);
-      
header.setColumnToTsBlockIndexMap(Collections.singletonList(outputColumnName));
-
-      TSExecuteStatementResp resp = createResponse(header, 1);
-      TSQueryDataSet queryDataSet = convertTsBlockByFetchSize(blockResult);
-      resp.setQueryDataSet(queryDataSet);
-
-      return resp;
-    } catch (Exception e) {
-      return RpcUtils.getTSExecuteStatementResp(
-          onQueryException(e, "\"" + req + "\". " + 
OperationType.EXECUTE_AGG_QUERY));
-    } finally {
-      SESSION_MANAGER.updateIdleTime();
-    }
-  }
-
   @Override
   public TSFetchResultsResp fetchResultsV2(TSFetchResultsReq req) {
     long startTime = System.nanoTime();

Reply via email to