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:53 UTC
[incubator-iotdb] branch master updated: change the default fetch
size in session
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 7f95b1a change the default fetch size in session
7f95b1a is described below
commit 7f95b1aea75205b0f460a14fcbd2464f12a2f075
Author: JackieTien97 <Ja...@foxmail.com>
AuthorDate: Thu Jul 16 16:30:31 2020 +0800
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 06a5f21..a6cc09f 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() {