You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2020/07/16 10:23:34 UTC
[incubator-iotdb] branch rel/0.10 updated: Change the default fetch
size in session (#1506)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch rel/0.10
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/rel/0.10 by this push:
new 0daa643 Change the default fetch size in session (#1506)
0daa643 is described below
commit 0daa643e056b6ff88ef34f7b73380985d15451f6
Author: Jackie Tien <Ja...@foxmail.com>
AuthorDate: Thu Jul 16 18:23:25 2020 +0800
Change the default fetch size in session (#1506)
* change the default fetch size in session
---
example/session/src/main/java/org/apache/iotdb/SessionExample.java | 4 ++--
session/src/main/java/org/apache/iotdb/session/SessionDataSet.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionExample.java b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
index 01b05e5..36b30c6 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
@@ -342,7 +342,7 @@ public class SessionExample {
SessionDataSet dataSet;
dataSet = session.executeQueryStatement("select * from root.sg1.d1");
System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024); // default is 512
+ dataSet.setFetchSize(1024); // default is 10000
while (dataSet.hasNext()) {
System.out.println(dataSet.next());
}
@@ -356,7 +356,7 @@ public class SessionExample {
dataSet = session.executeQueryStatement("select * from root.sg1.d1");
DataIterator iterator = dataSet.iterator();
System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024); // default is 512
+ dataSet.setFetchSize(1024); // default is 10000
while (iterator.next()) {
StringBuilder builder = new StringBuilder();
// get time
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 b1708f8..f264ece 100644
--- a/session/src/main/java/org/apache/iotdb/session/SessionDataSet.java
+++ b/session/src/main/java/org/apache/iotdb/session/SessionDataSet.java
@@ -45,8 +45,8 @@ public class SessionDataSet {
Map<String, Integer> columnNameIndex,
long queryId, TSIService.Iface client, long sessionId, TSQueryDataSet queryDataSet,
boolean ignoreTimeStamp) {
- this.ioTDBRpcDataSet = new IoTDBRpcDataSet(sql, columnNameList, columnTypeList,
- columnNameIndex, ignoreTimeStamp, queryId, client, sessionId, queryDataSet, 1024);
+ this.ioTDBRpcDataSet = new IoTDBRpcDataSet(sql, columnNameList, columnTypeList, columnNameIndex,
+ ignoreTimeStamp, queryId, client, sessionId, queryDataSet, Config.DEFAULT_FETCH_SIZE);
}
public int getFetchSize() {