save query result
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTest8.java b/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTest8.java
index c9187d9..e3a8a2c 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTest8.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTest8.java
@@ -19,13 +19,6 @@
package org.apache.iotdb.db.integration.m4;
-import static org.junit.Assert.fail;
-
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.ResultSet;
-import java.sql.Statement;
-import java.util.Locale;
import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.engine.compaction.CompactionStrategy;
@@ -33,11 +26,20 @@
import org.apache.iotdb.jdbc.Config;
import org.apache.iotdb.jdbc.IoTDBStatement;
import org.apache.iotdb.tsfile.common.conf.TSFileDescriptor;
+
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.Statement;
+import java.util.Locale;
+
+import static org.junit.Assert.fail;
+
public class MyTest8 {
// test MinMax-LSM
private static final String TIMESTAMP_STR = "Time";
@@ -94,12 +96,7 @@
prepareData1();
String[] res =
- new String[] {
- "0,5[1],30[10]",
- "25,8[25],40[30]",
- "50,8[52],18[54]",
- "75,null,null"
- };
+ new String[] {"0,5[1],30[10]", "25,8[25],40[30]", "50,8[52],18[54]", "75,null,null"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
Statement statement = connection.createStatement()) {
@@ -139,12 +136,7 @@
prepareData5();
String[] res =
- new String[] {
- "0,5[1],30[10]",
- "25,8[25],40[30]",
- "50,null,null",
- "75,null,null"
- };
+ new String[] {"0,5[1],30[10]", "25,8[25],40[30]", "50,null,null", "75,null,null"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
Statement statement = connection.createStatement()) {
@@ -266,12 +258,7 @@
prepareData2();
String[] res =
- new String[] {
- "0,5[1],30[10]",
- "25,8[25],20[27]",
- "50,null,null",
- "75,null,null"
- };
+ new String[] {"0,5[1],30[10]", "25,8[25],20[27]", "50,null,null", "75,null,null"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
Statement statement = connection.createStatement()) {
@@ -394,12 +381,7 @@
prepareData3();
String[] res =
- new String[] {
- "0,1[10],10[2]",
- "25,2[40],8[30]",
- "50,4[72],20[62]",
- "75,1[90],11[80]"
- };
+ new String[] {"0,1[10],10[2]", "25,2[40],8[30]", "50,4[72],20[62]", "75,1[90],11[80]"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
Statement statement = connection.createStatement()) {
@@ -474,12 +456,7 @@
prepareData3_2();
String[] res =
- new String[] {
- "0,1[10],10[2]",
- "25,2[40],8[30]",
- "50,4[72],20[62]",
- "75,1[90],11[80]"
- };
+ new String[] {"0,1[10],10[2]", "25,2[40],8[30]", "50,4[72],20[62]", "75,1[90],11[80]"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
Statement statement = connection.createStatement()) {
@@ -554,12 +531,7 @@
prepareData4();
String[] res =
- new String[] {
- "0,5[1],30[10]",
- "25,8[25],30[45]",
- "50,8[52],18[54]",
- "75,null,null"
- };
+ new String[] {"0,5[1],30[10]", "25,8[25],30[45]", "50,8[52],18[54]", "75,null,null"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
Statement statement = connection.createStatement()) {
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 bb07532..4e3c586 100644
--- a/session/src/main/java/org/apache/iotdb/session/SessionDataSet.java
+++ b/session/src/main/java/org/apache/iotdb/session/SessionDataSet.java
@@ -41,7 +41,7 @@
public class SessionDataSet {
- private final IoTDBRpcDataSet ioTDBRpcDataSet;
+ public final IoTDBRpcDataSet ioTDBRpcDataSet;
private String finishResult;
public SessionDataSet(
