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();