[iotdb] 01/05: add interface in thrift

[hu...@apache.org]

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

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

commit 9d6cd39831f6d5d5dc24cc3a5d56e72bf04f3afd
Author: Minghui Liu <li...@foxmail.com>
AuthorDate: Wed Dec 28 16:27:18 2022 +0800

    add interface in thrift
---
 thrift-commons/src/main/thrift/common.thrift |  4 ++++
 thrift/src/main/thrift/client.thrift         | 23 +++++++++++++++++++----
 2 files changed, 23 insertions(+), 4 deletions(-)

diff --git a/thrift-commons/src/main/thrift/common.thrift b/thrift-commons/src/main/thrift/common.thrift
index fecceb80a8..b10f9f1945 100644
--- a/thrift-commons/src/main/thrift/common.thrift
+++ b/thrift-commons/src/main/thrift/common.thrift
@@ -123,3 +123,7 @@ struct TFilesResp {
   1: required TSStatus status
   2: required list<TFile> files
 }
+
+struct TPartialPath {
+  1: required list<string> nodes;
+}
\ No newline at end of file
diff --git a/thrift/src/main/thrift/client.thrift b/thrift/src/main/thrift/client.thrift
index ec216613ea..e8c2167efe 100644
--- a/thrift/src/main/thrift/client.thrift
+++ b/thrift/src/main/thrift/client.thrift
@@ -320,8 +320,8 @@ struct TSRawDataQueryReq {
   4: required i64 startTime
   5: required i64 endTime
   6: required i64 statementId
-  7: optional bool enableRedirectQuery;
-  8: optional bool jdbcQuery;
+  7: optional bool enableRedirectQuery
+  8: optional bool jdbcQuery
   9: optional i64 timeout
 }
 
@@ -331,11 +331,24 @@ struct TSLastDataQueryReq {
   3: optional i32 fetchSize
   4: required i64 time
   5: required i64 statementId
-  6: optional bool enableRedirectQuery;
-  7: optional bool jdbcQuery;
+  6: optional bool enableRedirectQuery
+  7: optional bool jdbcQuery
   8: optional i64 timeout
 }
 
+struct TSAggregationQueryReq {
+  1: required i64 sessionId
+  2: required i64 statementId
+  3: required list<common.TPartialPath> paths
+  4: required list<string> aggregations
+  5: optional i64 startTime
+  6: optional i64 endTime
+  7: optional i64 interval
+  8: optional i64 slidingStep
+  9: optional i32 fetchSize
+  10: optional i64 timeout
+}
+
 struct TSCreateMultiTimeseriesReq {
   1: required i64 sessionId
   2: required list<string> paths
@@ -469,6 +482,8 @@ service IClientRPCService {
 
   TSExecuteStatementResp executeLastDataQueryV2(1:TSLastDataQueryReq req);
 
+  TSExecuteStatementResp executeAggregationQuery(1:TSAggregationQueryReq req);
+
   TSFetchResultsResp fetchResultsV2(1:TSFetchResultsReq req);
 
   TSOpenSessionResp openSession(1:TSOpenSessionReq req);