You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/01/03 12:41:10 UTC
[iotdb] branch rel/1.0 updated: [To rel/1.0][IOTDB-5316] fix bug that Session.setFetchSize is not used in the following fetch requests
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch rel/1.0
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rel/1.0 by this push:
new 09dfb351fa [To rel/1.0][IOTDB-5316] fix bug that Session.setFetchSize is not used in the following fetch requests
09dfb351fa is described below
commit 09dfb351fafe639a2f89893dd0d4a7ed78f77b95
Author: Rui,Lei <33...@users.noreply.github.com>
AuthorDate: Tue Jan 3 20:41:05 2023 +0800
[To rel/1.0][IOTDB-5316] fix bug that Session.setFetchSize is not used in the following fetch requests
---
.../apache/iotdb/session/SessionConnection.java | 3 ++-
.../org/apache/iotdb/session/SessionDataSet.java | 31 ++++++++++++++++++++++
2 files changed, 33 insertions(+), 1 deletion(-)
diff --git a/session/src/main/java/org/apache/iotdb/session/SessionConnection.java b/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
index 184189ca01..4fa154dc6a 100644
--- a/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
+++ b/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
@@ -380,7 +380,8 @@ public class SessionConnection {
execResp.queryResult,
execResp.isIgnoreTimeStamp(),
timeout,
- execResp.moreData);
+ execResp.moreData,
+ session.fetchSize);
}
protected void executeNonQueryStatement(String sql)
diff --git a/session/src/main/java/org/apache/iotdb/session/SessionDataSet.java b/session/src/main/java/org/apache/iotdb/session/SessionDataSet.java
index b9eb94a43d..bd03723f03 100644
--- a/session/src/main/java/org/apache/iotdb/session/SessionDataSet.java
+++ b/session/src/main/java/org/apache/iotdb/session/SessionDataSet.java
@@ -103,6 +103,37 @@ public class SessionDataSet implements ISessionDataSet {
timeout);
}
+ public SessionDataSet(
+ String sql,
+ List<String> columnNameList,
+ List<String> columnTypeList,
+ Map<String, Integer> columnNameIndex,
+ long queryId,
+ long statementId,
+ IClientRPCService.Iface client,
+ long sessionId,
+ List<ByteBuffer> queryResult,
+ boolean ignoreTimeStamp,
+ long timeout,
+ boolean moreData,
+ int fetchSize) {
+ this.ioTDBRpcDataSet =
+ new IoTDBRpcDataSet(
+ sql,
+ columnNameList,
+ columnTypeList,
+ columnNameIndex,
+ ignoreTimeStamp,
+ moreData,
+ queryId,
+ statementId,
+ client,
+ sessionId,
+ queryResult,
+ fetchSize,
+ timeout);
+ }
+
@Override
public int getFetchSize() {
return ioTDBRpcDataSet.fetchSize;