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 0a4546c add iterator in SessionDataSetWrapper
0a4546c is described below
commit 0a4546c6a9acb1d686d0cc7fe3f42611e6599590
Author: qiaojialin <[email protected]>
AuthorDate: Mon May 11 23:13:44 2020 +0800
add iterator in SessionDataSetWrapper
---
.../java/org/apache/iotdb/session/pool/SessionDataSetWrapper.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git
a/session/src/main/java/org/apache/iotdb/session/pool/SessionDataSetWrapper.java
b/session/src/main/java/org/apache/iotdb/session/pool/SessionDataSetWrapper.java
index b8fa8d6..b319b86 100644
---
a/session/src/main/java/org/apache/iotdb/session/pool/SessionDataSetWrapper.java
+++
b/session/src/main/java/org/apache/iotdb/session/pool/SessionDataSetWrapper.java
@@ -23,6 +23,7 @@ import org.apache.iotdb.rpc.IoTDBConnectionException;
import org.apache.iotdb.rpc.StatementExecutionException;
import org.apache.iotdb.session.Session;
import org.apache.iotdb.session.SessionDataSet;
+import org.apache.iotdb.session.SessionDataSet.DataIterator;
import org.apache.iotdb.tsfile.read.common.RowRecord;
public class SessionDataSetWrapper {
@@ -75,6 +76,13 @@ public class SessionDataSetWrapper {
return sessionDataSet.next();
}
+ /**
+ * retrieve data set like jdbc
+ */
+ public DataIterator iterator() {
+ return sessionDataSet.iterator();
+ }
+
public List<String> getColumnNames() {
return sessionDataSet.getColumnNames();
}