(paths []string, aggregations []common.TAggregationType, startTime *int64, endTime *int64, interval *int64, timeoutMs *int64, legalNodes *bool, )
| 618 | } |
| 619 | |
| 620 | func (s *Session) ExecuteAggregationQueryWithLegalNodes(paths []string, aggregations []common.TAggregationType, |
| 621 | startTime *int64, endTime *int64, interval *int64, |
| 622 | timeoutMs *int64, legalNodes *bool, |
| 623 | ) (*SessionDataSet, error) { |
| 624 | request := rpc.TSAggregationQueryReq{ |
| 625 | SessionId: s.sessionId, StatementId: s.requestStatementId, Paths: paths, |
| 626 | Aggregations: aggregations, StartTime: startTime, EndTime: endTime, Interval: interval, FetchSize: &s.config.FetchSize, |
| 627 | Timeout: timeoutMs, LegalPathNodes: legalNodes, |
| 628 | } |
| 629 | if resp, err := s.client.ExecuteAggregationQueryV2(context.Background(), &request); err == nil { |
| 630 | if statusErr := VerifySuccess(resp.Status); statusErr == nil { |
| 631 | return NewSessionDataSet("", resp.Columns, resp.DataTypeList, resp.ColumnNameIndexMap, *resp.QueryId, s.requestStatementId, s.client, s.sessionId, resp.QueryResult_, resp.IgnoreTimeStamp != nil && *resp.IgnoreTimeStamp, timeoutMs, *resp.MoreData, s.config.FetchSize, s.config.TimeZone, s.timeFactor, resp.GetColumnIndex2TsBlockColumnIndexList()) |
| 632 | } else { |
| 633 | return nil, statusErr |
| 634 | } |
| 635 | } else { |
| 636 | if s.reconnect() { |
| 637 | request.SessionId = s.sessionId |
| 638 | resp, err = s.client.ExecuteAggregationQueryV2(context.Background(), &request) |
| 639 | if err == nil { |
| 640 | if resp == nil { |
| 641 | return nil, fmt.Errorf("received nil response after reconnect") |
| 642 | } |
| 643 | if statusErr := VerifySuccess(resp.Status); statusErr == nil { |
| 644 | return NewSessionDataSet("", resp.Columns, resp.DataTypeList, resp.ColumnNameIndexMap, *resp.QueryId, s.requestStatementId, s.client, s.sessionId, resp.QueryResult_, resp.IgnoreTimeStamp != nil && *resp.IgnoreTimeStamp, timeoutMs, *resp.MoreData, s.config.FetchSize, s.config.TimeZone, s.timeFactor, resp.GetColumnIndex2TsBlockColumnIndexList()) |
| 645 | } else { |
| 646 | return nil, statusErr |
| 647 | } |
| 648 | } |
| 649 | } |
| 650 | return nil, err |
| 651 | } |
| 652 | } |
| 653 | |
| 654 | func (s *Session) ExecuteFastLastDataQueryForOnePrefixPath(prefixes []string, timeoutMs *int64) (*SessionDataSet, error) { |
| 655 | request := rpc.TSFastLastDataQueryForOnePrefixPathReq{ |
no test coverage detected