You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by le...@apache.org on 2022/02/14 04:06:57 UTC
[iotdb] 23/32: prepare
This is an automated email from the ASF dual-hosted git repository.
leirui pushed a commit to branch research/M4-visualization
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit dae87d1bc16fc373e8e4a7a43e1c0ec230c52018
Author: Lei Rui <10...@qq.com>
AuthorDate: Tue Feb 8 03:58:52 2022 +0800
prepare
---
example/session/pom.xml | 6 +-
.../org/apache/iotdb/DataMigrationExample.java | 186 ------
.../src/main/java/org/apache/iotdb/MyTest.java | 109 ---
.../java/org/apache/iotdb/QueryExperiment.java | 95 ---
.../org/apache/iotdb/SessionConcurrentExample.java | 198 ------
.../main/java/org/apache/iotdb/SessionExample.java | 674 -------------------
.../java/org/apache/iotdb/SessionExample2.java | 57 --
.../java/org/apache/iotdb/SessionPoolExample.java | 121 ----
.../java/org/apache/iotdb/WriteCSVToIoTDB.java | 46 --
.../iotdb/mac/QueryFullGameExperimentMAC.java | 47 --
.../{QueryFullGame.java => QueryBallSpeed.java} | 2 +-
.../apache/iotdb/queryExp/QueryFullGame_old.java | 104 ---
.../queryExp/{QueryTianyuan.java => QueryKOB.java} | 2 +-
.../{QueryRecTime.java => QueryRcvTime.java} | 4 +-
.../iotdb/tools/iotdb-engine-example.properties | 740 +++++++++++++++++++++
.../org/apache/iotdb/tools/query_experiment.sh | 12 +
.../src/main/java/org/apache/iotdb/tools/tool.sh | 12 +
...FullGameData.java => ExtractBallSpeedData.java} | 5 +-
.../{ExtractTianyuan.java => ExtractKOBData.java} | 4 +-
...tractDebs2012Data.java => ExtractMF03Data.java} | 8 +-
...actRecTimeData.java => ExtractRcvTimeData.java} | 9 +-
...{OverlapFullGame.java => OverlapGenerator.java} | 10 +-
.../{WriteFullGame.java => WriteBallSpeed.java} | 3 +-
.../writeData/WriteFullGameDisorderedToIoTDB.java | 52 --
.../WriteFullGameDisorderedWithDeletes.java | 74 ---
.../iotdb/writeData/WriteFullGameToIoTDB.java | 54 --
.../apache/iotdb/writeData/WriteFullGame_old.java | 98 ---
.../{WriteTianyuan.java => WriteKOB.java} | 5 +-
.../java/org/apache/iotdb/writeData/WriteMF03.java | 6 +-
.../{WriteRecTime.java => WriteRcvTime.java} | 7 +-
.../iotdb/writeData/WriteSyntheticData1.java | 46 --
.../writeData/WriteSyntheticDataWithDeletes.java | 64 --
32 files changed, 790 insertions(+), 2070 deletions(-)
diff --git a/example/session/pom.xml b/example/session/pom.xml
index 2e8a63c..773b122 100644
--- a/example/session/pom.xml
+++ b/example/session/pom.xml
@@ -26,8 +26,8 @@
<version>0.12.4</version>
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>QueryFullGame</artifactId>
- <name>QueryFullGame</name>
+ <artifactId>WriteMF03</artifactId>
+ <name>WriteMF03</name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.7</maven.compiler.source>
@@ -61,7 +61,7 @@
<configuration>
<transformers>
<transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
- <mainClass>org.apache.iotdb.queryExp.QueryFullGame</mainClass>
+ <mainClass>org.apache.iotdb.writeData.WriteMF03</mainClass>
</transformer>
</transformers>
</configuration>
diff --git a/example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java b/example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java
deleted file mode 100644
index e880ba9..0000000
--- a/example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java
+++ /dev/null
@@ -1,186 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.iotdb;
-
-import org.apache.iotdb.rpc.IoTDBConnectionException;
-import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.session.SessionDataSet.DataIterator;
-import org.apache.iotdb.session.pool.SessionDataSetWrapper;
-import org.apache.iotdb.session.pool.SessionPool;
-import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-import org.apache.iotdb.tsfile.read.common.Path;
-import org.apache.iotdb.tsfile.utils.Binary;
-import org.apache.iotdb.tsfile.write.record.Tablet;
-import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.Callable;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.Future;
-
-/**
- * Migrate all data belongs to a path from one IoTDB to another IoTDB Each thread migrate one
- * series, the concurrent thread can be configured by concurrency
- *
- * <p>This example is migrating all timeseries from a local IoTDB with 6667 port to a local IoTDB
- * with 6668 port
- */
-public class DataMigrationExample {
-
- // used to read data from the source IoTDB
- private static SessionPool readerPool;
- // used to write data into the destination IoTDB
- private static SessionPool writerPool;
- // concurrent thread of loading timeseries data
- private static int concurrency = 5;
-
- public static void main(String[] args)
- throws IoTDBConnectionException, StatementExecutionException, ExecutionException,
- InterruptedException {
-
- ExecutorService executorService = Executors.newFixedThreadPool(2 * concurrency + 1);
-
- String path = "root";
-
- if (args.length != 0) {
- path = args[0];
- }
-
- readerPool = new SessionPool("127.0.0.1", 6667, "root", "root", concurrency);
- writerPool = new SessionPool("127.0.0.1", 6668, "root", "root", concurrency);
-
- SessionDataSetWrapper schemaDataSet =
- readerPool.executeQueryStatement("count timeseries " + path);
- DataIterator schemaIter = schemaDataSet.iterator();
- int total;
- if (schemaIter.next()) {
- total = schemaIter.getInt(1);
- System.out.println("Total timeseries: " + total);
- } else {
- System.out.println("Can not get timeseries schema");
- System.exit(1);
- }
- readerPool.closeResultSet(schemaDataSet);
-
- schemaDataSet = readerPool.executeQueryStatement("show timeseries " + path);
- schemaIter = schemaDataSet.iterator();
-
- List<Future> futureList = new ArrayList<>();
- int count = 0;
- while (schemaIter.next()) {
- count++;
- Path currentPath = new Path(schemaIter.getString("timeseries"), true);
- Future future =
- executorService.submit(
- new LoadThread(
- count, currentPath, TSDataType.valueOf(schemaIter.getString("dataType"))));
- futureList.add(future);
- }
- readerPool.closeResultSet(schemaDataSet);
-
- for (Future future : futureList) {
- future.get();
- }
- executorService.shutdown();
-
- readerPool.close();
- writerPool.close();
- }
-
- static class LoadThread implements Callable<Void> {
-
- String device;
- String measurement;
- Path series;
- TSDataType dataType;
- Tablet tablet;
- int i;
-
- public LoadThread(int i, Path series, TSDataType dataType) {
- this.i = i;
- this.device = series.getDevice();
- this.measurement = series.getMeasurement();
- this.dataType = dataType;
- this.series = series;
- }
-
- @Override
- public Void call() {
-
- List<MeasurementSchema> schemaList = new ArrayList<>();
- schemaList.add(new MeasurementSchema(measurement, dataType));
- tablet = new Tablet(device, schemaList, 300000);
- SessionDataSetWrapper dataSet = null;
-
- try {
-
- dataSet =
- readerPool.executeQueryStatement(
- String.format("select %s from %s", measurement, device));
-
- DataIterator dataIter = dataSet.iterator();
- while (dataIter.next()) {
- int row = tablet.rowSize++;
- tablet.timestamps[row] = dataIter.getLong(1);
- switch (dataType) {
- case BOOLEAN:
- ((boolean[]) tablet.values[0])[row] = dataIter.getBoolean(2);
- break;
- case INT32:
- ((int[]) tablet.values[0])[row] = dataIter.getInt(2);
- break;
- case INT64:
- ((long[]) tablet.values[0])[row] = dataIter.getLong(2);
- break;
- case FLOAT:
- ((float[]) tablet.values[0])[row] = dataIter.getFloat(2);
- break;
- case DOUBLE:
- ((double[]) tablet.values[0])[row] = dataIter.getDouble(2);
- break;
- case TEXT:
- ((Binary[]) tablet.values[0])[row] = new Binary(dataIter.getString(2));
- break;
- }
- if (tablet.rowSize == tablet.getMaxRowNumber()) {
- writerPool.insertTablet(tablet, true);
- tablet.reset();
- }
- }
- if (tablet.rowSize != 0) {
- writerPool.insertTablet(tablet);
- tablet.reset();
- }
-
- } catch (Exception e) {
- System.out.println(
- "Loading the " + i + "-th timeseries: " + series + " failed " + e.getMessage());
- return null;
- } finally {
- readerPool.closeResultSet(dataSet);
- }
-
- System.out.println("Loading the " + i + "-th timeseries: " + series + " success");
- return null;
- }
- }
-}
diff --git a/example/session/src/main/java/org/apache/iotdb/MyTest.java b/example/session/src/main/java/org/apache/iotdb/MyTest.java
deleted file mode 100644
index c7a0e08..0000000
--- a/example/session/src/main/java/org/apache/iotdb/MyTest.java
+++ /dev/null
@@ -1,109 +0,0 @@
-// package org.apache.iotdb;/*
-// * Licensed to the Apache Software Foundation (ASF) under one
-// * or more contributor license agreements. See the NOTICE file
-// * distributed with this work for additional information
-// * regarding copyright ownership. The ASF licenses this file
-// * to you under the Apache License, Version 2.0 (the
-// * "License"); you may not use this file except in compliance
-// * with the License. You may obtain a copy of the License at
-// *
-// * http://www.apache.org/licenses/LICENSE-2.0
-// *
-// * Unless required by applicable law or agreed to in writing,
-// * software distributed under the License is distributed on an
-// * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// * KIND, either express or implied. See the License for the
-// * specific language governing permissions and limitations
-// * under the License.
-// */
-//
-// import java.sql.Connection;
-// import java.sql.DriverManager;
-// 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;
-// import org.apache.iotdb.db.utils.EnvironmentUtils;
-// import org.apache.iotdb.jdbc.Config;
-// import org.junit.AfterClass;
-// import org.junit.BeforeClass;
-// import org.junit.Test;
-//
-// public class MyTest {
-//
-// private static String[] creationSqls =
-// new String[]{
-// "SET STORAGE GROUP TO root.vehicle.d0",
-// "CREATE TIMESERIES root.vehicle.d0.s0 WITH DATATYPE=FLOAT, ENCODING=plain",
-// };
-//
-// private final String d0s0 = "root.vehicle.d0.s0";
-//
-// private static final String insertTemplate =
-// "INSERT INTO root.vehicle.d0(timestamp,s0)" + " VALUES(%d,%f)";
-//
-// private static final IoTDBConfig ioTDBConfig = IoTDBDescriptor.getInstance().getConfig();
-// private static int avgSeriesPointNumberThreshold;
-//
-// @BeforeClass
-// public static void setUp() throws Exception {
-// avgSeriesPointNumberThreshold = ioTDBConfig.getAvgSeriesPointNumberThreshold();
-//
-// IoTDBDescriptor.getInstance().getConfig()
-// .setCompactionStrategy(CompactionStrategy.NO_COMPACTION);
-//
-// EnvironmentUtils.envSetUp();
-//
-// Class.forName(Config.JDBC_DRIVER_NAME);
-// }
-//
-// @AfterClass
-// public static void tearDown() throws Exception {
-//// EnvironmentUtils.cleanEnv();
-// IoTDBDescriptor.getInstance()
-// .getConfig()
-// .setCompactionStrategy(CompactionStrategy.LEVEL_COMPACTION);
-//
-// ioTDBConfig.setAvgSeriesPointNumberThreshold(avgSeriesPointNumberThreshold);
-// }
-//
-// @Test
-// public void test1() {
-// prepareData1();
-// }
-//
-// private static void prepareData1() {
-// try (Connection connection =
-// DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
-// Statement statement = connection.createStatement()) {
-//
-// String[] creationSqls =
-// new String[]{
-// "SET STORAGE GROUP TO root.vehicle.d0",
-// "CREATE TIMESERIES root.vehicle.d0.s0 WITH DATATYPE=FLOAT,
-// ENCODING = plain",
-// };
-// for (String sql : creationSqls) {
-// statement.execute(sql);
-// }
-//
-// String insertTemplate =
-// "INSERT INTO root.vehicle.d0(timestamp,s0)" + " VALUES(%d,%f)";
-//
-// ioTDBConfig.setSeqTsFileSize(1024 * 1024 * 1024);// 1G
-// ioTDBConfig.setUnSeqTsFileSize(1024 * 1024 * 1024); // 1G
-// ioTDBConfig.setAvgSeriesPointNumberThreshold(10000); // this step cannot be omitted
-//
-// for (int i = 1; i <= 50000; i++) {
-// statement.addBatch(String.format(Locale.ENGLISH, insertTemplate, i,
-// Math.random()));
-// }
-// statement.executeBatch();
-// statement.clearBatch();
-// statement.execute("flush");
-// } catch (Exception e) {
-// e.printStackTrace();
-// }
-// }
-// }
diff --git a/example/session/src/main/java/org/apache/iotdb/QueryExperiment.java b/example/session/src/main/java/org/apache/iotdb/QueryExperiment.java
deleted file mode 100644
index 303db60..0000000
--- a/example/session/src/main/java/org/apache/iotdb/QueryExperiment.java
+++ /dev/null
@@ -1,95 +0,0 @@
-package org.apache.iotdb;
-
-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.tsfile.read.common.RowRecord;
-
-import org.apache.thrift.TException;
-
-import java.util.Random;
-
-public class QueryExperiment {
-
- private static Session session;
- private static final String timeseries =
- "root.kobelco.trans.03.1090001603.2401604.KOB_0002_00_67";
- private static final String queryFormat =
- "select min_time(%s), max_time(%s), first_value(%s), last_value(%s), min_value(%s), max_value(%s) "
- + "from %s "
- + "group by ([%d, %d), %dms)";
- private static final long totalIntervalLengthMS = 1 * 60 * 60 * 1000L;
- private static final int totalIntervalNumber = 1000;
- private static Random random = new Random(System.currentTimeMillis());
- private static final int sqlNum = 1;
-
- public static void main(String[] args)
- throws IoTDBConnectionException, StatementExecutionException, TException {
-
- String[] split = timeseries.split("\\.");
- String measurement = split[split.length - 1];
- String device = timeseries.replace("." + measurement, "");
-
- session = new Session("127.0.0.1", 6667, "root", "root");
- session.open(false);
-
- SessionDataSet dataSet;
-
- // dataSet =
- // session.executeQueryStatement(
- // "select min_time(" + measurement + "), max_time(" + measurement + ") from " +
- // device);
- // long minTime = -1;
- // long maxTime = -1;
- // while (dataSet.hasNext()) {
- // RowRecord r = dataSet.next();
- // minTime = r.getFields().get(0).getLongV();
- // maxTime = r.getFields().get(1).getLongV();
- // System.out.println(minTime + ", " + maxTime);
- // }
- // assert minTime != -1;
- // assert maxTime != -1;
-
- long minTime = 1616805035973L;
- long maxTime = 1627380839563L;
-
- for (int i = 0; i < sqlNum; i++) {
- long startTime = nextLong(minTime, maxTime - totalIntervalLengthMS);
- long endTime = startTime + totalIntervalLengthMS;
- String sql =
- String.format(
- queryFormat,
- measurement,
- measurement,
- measurement,
- measurement,
- measurement,
- measurement,
- device,
- startTime,
- endTime,
- (int) (totalIntervalLengthMS / totalIntervalNumber));
- dataSet = session.executeQueryStatement(sql);
- while (dataSet.hasNext()) {
- RowRecord r = dataSet.next();
- }
- session.executeNonQueryStatement("clear cache");
- }
-
- dataSet = session.executeFinish();
- String info = dataSet.getFinishResult();
-
- System.out.println(info);
-
- dataSet.closeOperationHandle();
- session.close();
- }
-
- public static long nextLong(long min, long max) {
- if (max <= min) {
- throw new IllegalArgumentException("max is less than min!");
- }
- return (long) (random.nextDouble() * (max - min)) + min;
- }
-}
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionConcurrentExample.java b/example/session/src/main/java/org/apache/iotdb/SessionConcurrentExample.java
deleted file mode 100644
index fb0f793..0000000
--- a/example/session/src/main/java/org/apache/iotdb/SessionConcurrentExample.java
+++ /dev/null
@@ -1,198 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.iotdb;
-
-import org.apache.iotdb.rpc.IoTDBConnectionException;
-import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.session.Session;
-import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType;
-import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
-import org.apache.iotdb.tsfile.write.record.Tablet;
-import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Random;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-
-public class SessionConcurrentExample {
-
- private static final int sgNum = 20;
- private static final int deviceNum = 100;
- private static final int parallelDegreeForOneSG = 3;
-
- public static void main(String[] args)
- throws IoTDBConnectionException, StatementExecutionException {
-
- Session session = new Session("127.0.0.1", 6667, "root", "root");
- session.open(false);
- createTemplate(session);
- session.close();
-
- CountDownLatch latch = new CountDownLatch(sgNum * parallelDegreeForOneSG);
- ExecutorService es = Executors.newFixedThreadPool(sgNum * parallelDegreeForOneSG);
-
- for (int i = 0; i < sgNum * parallelDegreeForOneSG; i++) {
- int currentIndex = i;
- es.execute(() -> concurrentOperation(latch, currentIndex));
- }
-
- es.shutdown();
-
- try {
- latch.await();
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
-
- private static void concurrentOperation(CountDownLatch latch, int currentIndex) {
-
- Session tmpSession = new Session("127.0.0.1", 6667, "root", "root");
- try {
- tmpSession.open(false);
- } catch (IoTDBConnectionException e) {
- e.printStackTrace();
- }
-
- for (int j = 0; j < deviceNum; j++) {
- try {
- insertTablet(
- tmpSession, String.format("root.sg_%d.d_%d", currentIndex / parallelDegreeForOneSG, j));
- } catch (IoTDBConnectionException | StatementExecutionException e) {
- e.printStackTrace();
- }
- }
-
- try {
- tmpSession.close();
- } catch (IoTDBConnectionException e) {
- e.printStackTrace();
- }
-
- latch.countDown();
- }
-
- private static void createTemplate(Session session)
- throws IoTDBConnectionException, StatementExecutionException {
- List<List<String>> measurementList = new ArrayList<>();
- measurementList.add(Collections.singletonList("s1"));
- measurementList.add(Collections.singletonList("s2"));
- measurementList.add(Collections.singletonList("s3"));
-
- List<List<TSDataType>> dataTypeList = new ArrayList<>();
- dataTypeList.add(Collections.singletonList(TSDataType.INT64));
- dataTypeList.add(Collections.singletonList(TSDataType.INT64));
- dataTypeList.add(Collections.singletonList(TSDataType.INT64));
-
- List<List<TSEncoding>> encodingList = new ArrayList<>();
- encodingList.add(Collections.singletonList(TSEncoding.RLE));
- encodingList.add(Collections.singletonList(TSEncoding.RLE));
- encodingList.add(Collections.singletonList(TSEncoding.RLE));
-
- List<CompressionType> compressionTypes = new ArrayList<>();
- for (int i = 0; i < 3; i++) {
- compressionTypes.add(CompressionType.SNAPPY);
- }
- List<String> schemaNames = new ArrayList<>();
- schemaNames.add("s1");
- schemaNames.add("s2");
- schemaNames.add("s3");
-
- session.createSchemaTemplate(
- "template1", schemaNames, measurementList, dataTypeList, encodingList, compressionTypes);
- for (int i = 0; i < sgNum; i++) {
- session.setSchemaTemplate("template1", "root.sg_" + i);
- }
- }
-
- /**
- * insert the data of a device. For each timestamp, the number of measurements is the same.
- *
- * <p>Users need to control the count of Tablet and write a batch when it reaches the maxBatchSize
- */
- private static void insertTablet(Session session, String deviceId)
- throws IoTDBConnectionException, StatementExecutionException {
- /*
- * A Tablet example:
- * device1
- * time s1, s2, s3
- * 1, 1, 1, 1
- * 2, 2, 2, 2
- * 3, 3, 3, 3
- */
- // The schema of measurements of one device
- // only measurementId and data type in MeasurementSchema take effects in Tablet
- List<MeasurementSchema> schemaList = new ArrayList<>();
- schemaList.add(new MeasurementSchema("s1", TSDataType.INT64));
- schemaList.add(new MeasurementSchema("s2", TSDataType.INT64));
- schemaList.add(new MeasurementSchema("s3", TSDataType.INT64));
-
- Tablet tablet = new Tablet(deviceId, schemaList, 100);
-
- // Method 1 to add tablet data
- long timestamp = System.currentTimeMillis();
-
- for (long row = 0; row < 100; row++) {
- int rowIndex = tablet.rowSize++;
- tablet.addTimestamp(rowIndex, timestamp);
- for (int s = 0; s < 3; s++) {
- long value = new Random().nextLong();
- tablet.addValue(schemaList.get(s).getMeasurementId(), rowIndex, value);
- }
- if (tablet.rowSize == tablet.getMaxRowNumber()) {
- session.insertTablet(tablet, true);
- tablet.reset();
- }
- timestamp++;
- }
-
- if (tablet.rowSize != 0) {
- session.insertTablet(tablet);
- tablet.reset();
- }
-
- // Method 2 to add tablet data
- long[] timestamps = tablet.timestamps;
- Object[] values = tablet.values;
-
- for (long time = 0; time < 100; time++) {
- int row = tablet.rowSize++;
- timestamps[row] = time;
- for (int i = 0; i < 3; i++) {
- long[] sensor = (long[]) values[i];
- sensor[row] = i;
- }
- if (tablet.rowSize == tablet.getMaxRowNumber()) {
- session.insertTablet(tablet, true);
- tablet.reset();
- }
- }
-
- if (tablet.rowSize != 0) {
- session.insertTablet(tablet);
- tablet.reset();
- }
- }
-}
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionExample.java b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
deleted file mode 100644
index 623f813..0000000
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ /dev/null
@@ -1,674 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.iotdb;
-
-import org.apache.iotdb.rpc.IoTDBConnectionException;
-import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.rpc.TSStatusCode;
-import org.apache.iotdb.session.Session;
-import org.apache.iotdb.session.SessionDataSet;
-import org.apache.iotdb.session.SessionDataSet.DataIterator;
-import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType;
-import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
-import org.apache.iotdb.tsfile.write.record.Tablet;
-import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Random;
-
-@SuppressWarnings("squid:S106")
-public class SessionExample {
-
- private static Session session;
- private static Session sessionEnableRedirect;
- private static final String ROOT_SG1_D1_S1 = "root.sg1.d1.s1";
- private static final String ROOT_SG1_D1_S2 = "root.sg1.d1.s2";
- private static final String ROOT_SG1_D1_S3 = "root.sg1.d1.s3";
- private static final String ROOT_SG1_D1_S4 = "root.sg1.d1.s4";
- private static final String ROOT_SG1_D1_S5 = "root.sg1.d1.s5";
- private static final String ROOT_SG1_D1 = "root.sg1.d1";
- private static final String LOCAL_HOST = "127.0.0.1";
-
- public static void main(String[] args)
- throws IoTDBConnectionException, StatementExecutionException {
- session = new Session(LOCAL_HOST, 6667, "root", "root");
- session.open(false);
-
- // set session fetchSize
- session.setFetchSize(10000);
-
- try {
- session.setStorageGroup("root.sg1");
- } catch (StatementExecutionException e) {
- if (e.getStatusCode() != TSStatusCode.PATH_ALREADY_EXIST_ERROR.getStatusCode()) {
- throw e;
- }
- }
-
- // createTemplate();
- createTimeseries();
- createMultiTimeseries();
- insertRecord();
- insertTablet();
- insertTablets();
- insertRecords();
- nonQuery();
- query();
- queryWithTimeout();
- rawDataQuery();
- queryByIterator();
- deleteData();
- deleteTimeseries();
- setTimeout();
-
- sessionEnableRedirect = new Session(LOCAL_HOST, 6667, "root", "root");
- sessionEnableRedirect.setEnableQueryRedirection(true);
- sessionEnableRedirect.open(false);
-
- // set session fetchSize
- sessionEnableRedirect.setFetchSize(10000);
-
- insertRecord4Redirect();
- query4Redirect();
- sessionEnableRedirect.close();
- session.close();
- }
-
- private static void createTimeseries()
- throws IoTDBConnectionException, StatementExecutionException {
-
- if (!session.checkTimeseriesExists(ROOT_SG1_D1_S1)) {
- session.createTimeseries(
- ROOT_SG1_D1_S1, TSDataType.INT64, TSEncoding.RLE, CompressionType.SNAPPY);
- }
- if (!session.checkTimeseriesExists(ROOT_SG1_D1_S2)) {
- session.createTimeseries(
- ROOT_SG1_D1_S2, TSDataType.INT64, TSEncoding.RLE, CompressionType.SNAPPY);
- }
- if (!session.checkTimeseriesExists(ROOT_SG1_D1_S3)) {
- session.createTimeseries(
- ROOT_SG1_D1_S3, TSDataType.INT64, TSEncoding.RLE, CompressionType.SNAPPY);
- }
-
- // create timeseries with tags and attributes
- if (!session.checkTimeseriesExists(ROOT_SG1_D1_S4)) {
- Map<String, String> tags = new HashMap<>();
- tags.put("tag1", "v1");
- Map<String, String> attributes = new HashMap<>();
- tags.put("description", "v1");
- session.createTimeseries(
- ROOT_SG1_D1_S4,
- TSDataType.INT64,
- TSEncoding.RLE,
- CompressionType.SNAPPY,
- null,
- tags,
- attributes,
- "temperature");
- }
-
- // create timeseries with SDT property, SDT will take place when flushing
- if (!session.checkTimeseriesExists(ROOT_SG1_D1_S5)) {
- // COMPDEV is required
- // COMPMAXTIME and COMPMINTIME are optional and their unit is ms
- Map<String, String> props = new HashMap<>();
- props.put("LOSS", "sdt");
- props.put("COMPDEV", "0.01");
- props.put("COMPMINTIME", "2");
- props.put("COMPMAXTIME", "10");
- session.createTimeseries(
- ROOT_SG1_D1_S5,
- TSDataType.INT64,
- TSEncoding.RLE,
- CompressionType.SNAPPY,
- props,
- null,
- null,
- null);
- }
- }
-
- private static void createMultiTimeseries()
- throws IoTDBConnectionException, StatementExecutionException {
-
- if (!session.checkTimeseriesExists("root.sg1.d2.s1")
- && !session.checkTimeseriesExists("root.sg1.d2.s2")) {
- List<String> paths = new ArrayList<>();
- paths.add("root.sg1.d2.s1");
- paths.add("root.sg1.d2.s2");
- List<TSDataType> tsDataTypes = new ArrayList<>();
- tsDataTypes.add(TSDataType.INT64);
- tsDataTypes.add(TSDataType.INT64);
- List<TSEncoding> tsEncodings = new ArrayList<>();
- tsEncodings.add(TSEncoding.RLE);
- tsEncodings.add(TSEncoding.RLE);
- List<CompressionType> compressionTypes = new ArrayList<>();
- compressionTypes.add(CompressionType.SNAPPY);
- compressionTypes.add(CompressionType.SNAPPY);
-
- List<Map<String, String>> tagsList = new ArrayList<>();
- Map<String, String> tags = new HashMap<>();
- tags.put("unit", "kg");
- tagsList.add(tags);
- tagsList.add(tags);
-
- List<Map<String, String>> attributesList = new ArrayList<>();
- Map<String, String> attributes = new HashMap<>();
- attributes.put("minValue", "1");
- attributes.put("maxValue", "100");
- attributesList.add(attributes);
- attributesList.add(attributes);
-
- List<String> alias = new ArrayList<>();
- alias.add("weight1");
- alias.add("weight2");
-
- session.createMultiTimeseries(
- paths, tsDataTypes, tsEncodings, compressionTypes, null, tagsList, attributesList, alias);
- }
- }
-
- private static void createTemplate()
- throws IoTDBConnectionException, StatementExecutionException {
- List<List<String>> measurementList = new ArrayList<>();
- measurementList.add(Collections.singletonList("s1"));
- measurementList.add(Collections.singletonList("s2"));
- measurementList.add(Collections.singletonList("s3"));
-
- List<List<TSDataType>> dataTypeList = new ArrayList<>();
- dataTypeList.add(Collections.singletonList(TSDataType.INT64));
- dataTypeList.add(Collections.singletonList(TSDataType.INT64));
- dataTypeList.add(Collections.singletonList(TSDataType.INT64));
-
- List<List<TSEncoding>> encodingList = new ArrayList<>();
- encodingList.add(Collections.singletonList(TSEncoding.RLE));
- encodingList.add(Collections.singletonList(TSEncoding.RLE));
- encodingList.add(Collections.singletonList(TSEncoding.RLE));
-
- List<CompressionType> compressionTypes = new ArrayList<>();
- for (int i = 0; i < 3; i++) {
- compressionTypes.add(CompressionType.SNAPPY);
- }
- List<String> schemaNames = new ArrayList<>();
- schemaNames.add("s1");
- schemaNames.add("s2");
- schemaNames.add("s3");
-
- session.createSchemaTemplate(
- "template1", schemaNames, measurementList, dataTypeList, encodingList, compressionTypes);
- session.setSchemaTemplate("template1", "root.sg1");
- }
-
- private static void insertRecord() throws IoTDBConnectionException, StatementExecutionException {
- String deviceId = ROOT_SG1_D1;
- List<String> measurements = new ArrayList<>();
- List<TSDataType> types = new ArrayList<>();
- measurements.add("s1");
- measurements.add("s2");
- measurements.add("s3");
- types.add(TSDataType.INT64);
- types.add(TSDataType.INT64);
- types.add(TSDataType.INT64);
-
- for (long time = 0; time < 100; time++) {
- List<Object> values = new ArrayList<>();
- values.add(1L);
- values.add(2L);
- values.add(3L);
- session.insertRecord(deviceId, time, measurements, types, values);
- }
- }
-
- private static void insertRecord4Redirect()
- throws IoTDBConnectionException, StatementExecutionException {
- for (int i = 0; i < 6; i++) {
- for (int j = 0; j < 2; j++) {
- String deviceId = "root.redirect" + i + ".d" + j;
- List<String> measurements = new ArrayList<>();
- measurements.add("s1");
- measurements.add("s2");
- measurements.add("s3");
- List<TSDataType> types = new ArrayList<>();
- types.add(TSDataType.INT64);
- types.add(TSDataType.INT64);
- types.add(TSDataType.INT64);
-
- for (long time = 0; time < 5; time++) {
- List<Object> values = new ArrayList<>();
- values.add(1L + time);
- values.add(2L + time);
- values.add(3L + time);
- session.insertRecord(deviceId, time, measurements, types, values);
- }
- }
- }
- }
-
- private static void insertStrRecord()
- throws IoTDBConnectionException, StatementExecutionException {
- String deviceId = ROOT_SG1_D1;
- List<String> measurements = new ArrayList<>();
- measurements.add("s1");
- measurements.add("s2");
- measurements.add("s3");
-
- for (long time = 0; time < 10; time++) {
- List<String> values = new ArrayList<>();
- values.add("1");
- values.add("2");
- values.add("3");
- session.insertRecord(deviceId, time, measurements, values);
- }
- }
-
- private static void insertRecordInObject()
- throws IoTDBConnectionException, StatementExecutionException {
- String deviceId = ROOT_SG1_D1;
- List<String> measurements = new ArrayList<>();
- List<TSDataType> types = new ArrayList<>();
- measurements.add("s1");
- measurements.add("s2");
- measurements.add("s3");
- types.add(TSDataType.INT64);
- types.add(TSDataType.INT64);
- types.add(TSDataType.INT64);
-
- for (long time = 0; time < 100; time++) {
- session.insertRecord(deviceId, time, measurements, types, 1L, 1L, 1L);
- }
- }
-
- private static void insertRecords() throws IoTDBConnectionException, StatementExecutionException {
- String deviceId = ROOT_SG1_D1;
- List<String> measurements = new ArrayList<>();
- measurements.add("s1");
- measurements.add("s2");
- measurements.add("s3");
- List<String> deviceIds = new ArrayList<>();
- List<List<String>> measurementsList = new ArrayList<>();
- List<List<Object>> valuesList = new ArrayList<>();
- List<Long> timestamps = new ArrayList<>();
- List<List<TSDataType>> typesList = new ArrayList<>();
-
- for (long time = 0; time < 500; time++) {
- List<Object> values = new ArrayList<>();
- List<TSDataType> types = new ArrayList<>();
- values.add(1L);
- values.add(2L);
- values.add(3L);
- types.add(TSDataType.INT64);
- types.add(TSDataType.INT64);
- types.add(TSDataType.INT64);
-
- deviceIds.add(deviceId);
- measurementsList.add(measurements);
- valuesList.add(values);
- typesList.add(types);
- timestamps.add(time);
- if (time != 0 && time % 100 == 0) {
- session.insertRecords(deviceIds, timestamps, measurementsList, typesList, valuesList);
- deviceIds.clear();
- measurementsList.clear();
- valuesList.clear();
- typesList.clear();
- timestamps.clear();
- }
- }
-
- session.insertRecords(deviceIds, timestamps, measurementsList, typesList, valuesList);
- }
-
- /**
- * insert the data of a device. For each timestamp, the number of measurements is the same.
- *
- * <p>Users need to control the count of Tablet and write a batch when it reaches the maxBatchSize
- */
- private static void insertTablet() throws IoTDBConnectionException, StatementExecutionException {
- /*
- * A Tablet example:
- * device1
- * time s1, s2, s3
- * 1, 1, 1, 1
- * 2, 2, 2, 2
- * 3, 3, 3, 3
- */
- // The schema of measurements of one device
- // only measurementId and data type in MeasurementSchema take effects in Tablet
- List<MeasurementSchema> schemaList = new ArrayList<>();
- schemaList.add(new MeasurementSchema("s1", TSDataType.INT64));
- schemaList.add(new MeasurementSchema("s2", TSDataType.INT64));
- schemaList.add(new MeasurementSchema("s3", TSDataType.INT64));
-
- Tablet tablet = new Tablet(ROOT_SG1_D1, schemaList, 100);
-
- // Method 1 to add tablet data
- long timestamp = System.currentTimeMillis();
-
- for (long row = 0; row < 100; row++) {
- int rowIndex = tablet.rowSize++;
- tablet.addTimestamp(rowIndex, timestamp);
- for (int s = 0; s < 3; s++) {
- long value = new Random().nextLong();
- tablet.addValue(schemaList.get(s).getMeasurementId(), rowIndex, value);
- }
- if (tablet.rowSize == tablet.getMaxRowNumber()) {
- session.insertTablet(tablet, true);
- tablet.reset();
- }
- timestamp++;
- }
-
- if (tablet.rowSize != 0) {
- session.insertTablet(tablet);
- tablet.reset();
- }
-
- // Method 2 to add tablet data
- long[] timestamps = tablet.timestamps;
- Object[] values = tablet.values;
-
- for (long time = 0; time < 100; time++) {
- int row = tablet.rowSize++;
- timestamps[row] = time;
- for (int i = 0; i < 3; i++) {
- long[] sensor = (long[]) values[i];
- sensor[row] = i;
- }
- if (tablet.rowSize == tablet.getMaxRowNumber()) {
- session.insertTablet(tablet, true);
- tablet.reset();
- }
- }
-
- if (tablet.rowSize != 0) {
- session.insertTablet(tablet);
- tablet.reset();
- }
- }
-
- private static void insertTablets() throws IoTDBConnectionException, StatementExecutionException {
- // The schema of measurements of one device
- // only measurementId and data type in MeasurementSchema take effects in Tablet
- List<MeasurementSchema> schemaList = new ArrayList<>();
- schemaList.add(new MeasurementSchema("s1", TSDataType.INT64));
- schemaList.add(new MeasurementSchema("s2", TSDataType.INT64));
- schemaList.add(new MeasurementSchema("s3", TSDataType.INT64));
-
- Tablet tablet1 = new Tablet(ROOT_SG1_D1, schemaList, 100);
- Tablet tablet2 = new Tablet("root.sg1.d2", schemaList, 100);
- Tablet tablet3 = new Tablet("root.sg1.d3", schemaList, 100);
-
- Map<String, Tablet> tabletMap = new HashMap<>();
- tabletMap.put(ROOT_SG1_D1, tablet1);
- tabletMap.put("root.sg1.d2", tablet2);
- tabletMap.put("root.sg1.d3", tablet3);
-
- // Method 1 to add tablet data
- long timestamp = System.currentTimeMillis();
- for (long row = 0; row < 100; row++) {
- int row1 = tablet1.rowSize++;
- int row2 = tablet2.rowSize++;
- int row3 = tablet3.rowSize++;
- tablet1.addTimestamp(row1, timestamp);
- tablet2.addTimestamp(row2, timestamp);
- tablet3.addTimestamp(row3, timestamp);
- for (int i = 0; i < 3; i++) {
- long value = new Random().nextLong();
- tablet1.addValue(schemaList.get(i).getMeasurementId(), row1, value);
- tablet2.addValue(schemaList.get(i).getMeasurementId(), row2, value);
- tablet3.addValue(schemaList.get(i).getMeasurementId(), row3, value);
- }
- if (tablet1.rowSize == tablet1.getMaxRowNumber()) {
- session.insertTablets(tabletMap, true);
- tablet1.reset();
- tablet2.reset();
- tablet3.reset();
- }
- timestamp++;
- }
-
- if (tablet1.rowSize != 0) {
- session.insertTablets(tabletMap, true);
- tablet1.reset();
- tablet2.reset();
- tablet3.reset();
- }
-
- // Method 2 to add tablet data
- long[] timestamps1 = tablet1.timestamps;
- Object[] values1 = tablet1.values;
- long[] timestamps2 = tablet2.timestamps;
- Object[] values2 = tablet2.values;
- long[] timestamps3 = tablet3.timestamps;
- Object[] values3 = tablet3.values;
-
- for (long time = 0; time < 100; time++) {
- int row1 = tablet1.rowSize++;
- int row2 = tablet2.rowSize++;
- int row3 = tablet3.rowSize++;
- timestamps1[row1] = time;
- timestamps2[row2] = time;
- timestamps3[row3] = time;
- for (int i = 0; i < 3; i++) {
- long[] sensor1 = (long[]) values1[i];
- sensor1[row1] = i;
- long[] sensor2 = (long[]) values2[i];
- sensor2[row2] = i;
- long[] sensor3 = (long[]) values3[i];
- sensor3[row3] = i;
- }
- if (tablet1.rowSize == tablet1.getMaxRowNumber()) {
- session.insertTablets(tabletMap, true);
-
- tablet1.reset();
- tablet2.reset();
- tablet3.reset();
- }
- }
-
- if (tablet1.rowSize != 0) {
- session.insertTablets(tabletMap, true);
- tablet1.reset();
- tablet2.reset();
- tablet3.reset();
- }
- }
-
- private static void deleteData() throws IoTDBConnectionException, StatementExecutionException {
- String path = ROOT_SG1_D1_S1;
- long deleteTime = 99;
- session.deleteData(path, deleteTime);
- }
-
- private static void deleteTimeseries()
- throws IoTDBConnectionException, StatementExecutionException {
- List<String> paths = new ArrayList<>();
- paths.add(ROOT_SG1_D1_S1);
- paths.add(ROOT_SG1_D1_S2);
- paths.add(ROOT_SG1_D1_S3);
- session.deleteTimeseries(paths);
- }
-
- private static void query() throws IoTDBConnectionException, StatementExecutionException {
- SessionDataSet dataSet = session.executeQueryStatement("select * from root.sg1.d1");
- System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024); // default is 10000
- while (dataSet.hasNext()) {
- System.out.println(dataSet.next());
- }
-
- dataSet.closeOperationHandle();
- }
-
- private static void query4Redirect()
- throws IoTDBConnectionException, StatementExecutionException {
- String selectPrefix = "select * from root.redirect";
- for (int i = 0; i < 6; i++) {
- SessionDataSet dataSet =
- sessionEnableRedirect.executeQueryStatement(selectPrefix + i + ".d1");
- System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024); // default is 10000
- while (dataSet.hasNext()) {
- System.out.println(dataSet.next());
- }
-
- dataSet.closeOperationHandle();
- }
-
- for (int i = 0; i < 6; i++) {
- SessionDataSet dataSet =
- sessionEnableRedirect.executeQueryStatement(
- selectPrefix + i + ".d1 where time >= 1 and time < 10");
- System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024); // default is 10000
- while (dataSet.hasNext()) {
- System.out.println(dataSet.next());
- }
-
- dataSet.closeOperationHandle();
- }
-
- for (int i = 0; i < 6; i++) {
- SessionDataSet dataSet =
- sessionEnableRedirect.executeQueryStatement(
- selectPrefix + i + ".d1 where time >= 1 and time < 10 align by device");
- System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024); // default is 10000
- while (dataSet.hasNext()) {
- System.out.println(dataSet.next());
- }
-
- dataSet.closeOperationHandle();
- }
-
- for (int i = 0; i < 6; i++) {
- SessionDataSet dataSet =
- sessionEnableRedirect.executeQueryStatement(
- selectPrefix
- + i
- + ".d1 where time >= 1 and time < 10 and root.redirect"
- + i
- + ".d1.s1 > 1");
- System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024); // default is 10000
- while (dataSet.hasNext()) {
- System.out.println(dataSet.next());
- }
-
- dataSet.closeOperationHandle();
- }
- }
-
- private static void queryWithTimeout()
- throws IoTDBConnectionException, StatementExecutionException {
- SessionDataSet dataSet = session.executeQueryStatement("select * from root.sg1.d1", 2000);
- System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024); // default is 10000
- while (dataSet.hasNext()) {
- System.out.println(dataSet.next());
- }
-
- dataSet.closeOperationHandle();
- }
-
- private static void rawDataQuery() throws IoTDBConnectionException, StatementExecutionException {
- List<String> paths = new ArrayList<>();
- paths.add(ROOT_SG1_D1_S1);
- paths.add(ROOT_SG1_D1_S2);
- paths.add(ROOT_SG1_D1_S3);
- long startTime = 10L;
- long endTime = 200L;
-
- SessionDataSet dataSet = session.executeRawDataQuery(paths, startTime, endTime);
- System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024);
- while (dataSet.hasNext()) {
- System.out.println(dataSet.next());
- }
- dataSet.closeOperationHandle();
- }
-
- private static void queryByIterator()
- throws IoTDBConnectionException, StatementExecutionException {
- SessionDataSet dataSet = session.executeQueryStatement("select * from root.sg1.d1");
- DataIterator iterator = dataSet.iterator();
- System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024); // default is 10000
- while (iterator.next()) {
- StringBuilder builder = new StringBuilder();
- // get time
- builder.append(iterator.getLong(1)).append(",");
- // get second column
- if (!iterator.isNull(2)) {
- builder.append(iterator.getLong(2)).append(",");
- } else {
- builder.append("null").append(",");
- }
-
- // get third column
- if (!iterator.isNull(ROOT_SG1_D1_S2)) {
- builder.append(iterator.getLong(ROOT_SG1_D1_S2)).append(",");
- } else {
- builder.append("null").append(",");
- }
-
- // get forth column
- if (!iterator.isNull(4)) {
- builder.append(iterator.getLong(4)).append(",");
- } else {
- builder.append("null").append(",");
- }
-
- // get fifth column
- if (!iterator.isNull(ROOT_SG1_D1_S4)) {
- builder.append(iterator.getObject(ROOT_SG1_D1_S4));
- } else {
- builder.append("null");
- }
-
- System.out.println(builder);
- }
-
- dataSet.closeOperationHandle();
- }
-
- private static void nonQuery() throws IoTDBConnectionException, StatementExecutionException {
- session.executeNonQueryStatement("insert into root.sg1.d1(timestamp,s1) values(200, 1)");
- }
-
- private static void setTimeout() throws StatementExecutionException {
- Session tempSession = new Session(LOCAL_HOST, 6667, "root", "root", 10000, 20000);
- tempSession.setQueryTimeout(60000);
- }
-
- private static void createClusterSession() throws IoTDBConnectionException {
- ArrayList<String> nodeList = new ArrayList<>();
- nodeList.add("127.0.0.1:6669");
- nodeList.add("127.0.0.1:6667");
- nodeList.add("127.0.0.1:6668");
- Session clusterSession = new Session(nodeList, "root", "root");
- clusterSession.open();
- clusterSession.close();
- }
-}
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionExample2.java b/example/session/src/main/java/org/apache/iotdb/SessionExample2.java
deleted file mode 100644
index 3638a50..0000000
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample2.java
+++ /dev/null
@@ -1,57 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.iotdb;
-
-import org.apache.iotdb.rpc.IoTDBConnectionException;
-import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.session.Session;
-import org.apache.iotdb.session.SessionDataSet;
-
-@SuppressWarnings("squid:S106")
-public class SessionExample2 {
-
- private static Session session;
- private static final String LOCAL_HOST = "127.0.0.1";
-
- static String statement1 =
- "select min_time(s1), first_value(s1), max_time(s1), last_value(s1), "
- + "min_value(s1), max_value(s1) from root.ln.ordered";
-
- static String statement2 =
- "select min_time(s1), first_value(s1), max_time(s1), last_value(s1), min_value(s1), max_value(s1) from root.ln.ordered";
-
- static String statement3 =
- "select min_time(s1), first_value(s1), max_time(s1), last_value(s1), min_value(s1), max_value(s1) from root.ln.ordered group by ([0, 10000), 1000ms)";
-
- public static void main(String[] args)
- throws IoTDBConnectionException, StatementExecutionException {
- session = new Session(LOCAL_HOST, 6667, "root", "root");
- session.open(false);
-
- SessionDataSet dataSet = session.executeQueryStatement(statement3);
- System.out.println(dataSet.getColumnNames());
- dataSet.setFetchSize(1024); // default is 10000
- while (dataSet.hasNext()) {
- System.out.println(dataSet.next());
- }
- dataSet.closeOperationHandle();
-
- session.close();
- }
-}
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java b/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
deleted file mode 100644
index d2e4977..0000000
--- a/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
+++ /dev/null
@@ -1,121 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.iotdb;
-
-import org.apache.iotdb.rpc.IoTDBConnectionException;
-import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.session.SessionDataSet.DataIterator;
-import org.apache.iotdb.session.pool.SessionDataSetWrapper;
-import org.apache.iotdb.session.pool.SessionPool;
-import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-
-public class SessionPoolExample {
-
- private static SessionPool pool;
- private static ExecutorService service;
-
- public static void main(String[] args)
- throws StatementExecutionException, IoTDBConnectionException, InterruptedException {
- pool = new SessionPool("127.0.0.1", 6667, "root", "root", 3);
- service = Executors.newFixedThreadPool(10);
-
- insertRecord();
- queryByRowRecord();
- Thread.sleep(1000);
- queryByIterator();
- pool.close();
- service.shutdown();
- }
-
- // more insert example, see SessionExample.java
- private static void insertRecord() throws StatementExecutionException, IoTDBConnectionException {
- String deviceId = "root.sg1.d1";
- List<String> measurements = new ArrayList<>();
- List<TSDataType> types = new ArrayList<>();
- measurements.add("s1");
- measurements.add("s2");
- measurements.add("s3");
- types.add(TSDataType.INT64);
- types.add(TSDataType.INT64);
- types.add(TSDataType.INT64);
-
- for (long time = 0; time < 10; time++) {
- List<Object> values = new ArrayList<>();
- values.add(1L);
- values.add(2L);
- values.add(3L);
- pool.insertRecord(deviceId, time, measurements, types, values);
- }
- }
-
- private static void queryByRowRecord() {
- for (int i = 0; i < 1; i++) {
- service.submit(
- () -> {
- SessionDataSetWrapper wrapper = null;
- try {
- wrapper = pool.executeQueryStatement("select * from root.sg1.d1");
- System.out.println(wrapper.getColumnNames());
- System.out.println(wrapper.getColumnTypes());
- while (wrapper.hasNext()) {
- System.out.println(wrapper.next());
- }
- } catch (IoTDBConnectionException | StatementExecutionException e) {
- e.printStackTrace();
- } finally {
- // remember to close data set finally!
- pool.closeResultSet(wrapper);
- }
- });
- }
- }
-
- private static void queryByIterator() {
- for (int i = 0; i < 1; i++) {
- service.submit(
- () -> {
- SessionDataSetWrapper wrapper = null;
- try {
- wrapper = pool.executeQueryStatement("select * from root.sg1.d1");
- // get DataIterator like JDBC
- DataIterator dataIterator = wrapper.iterator();
- System.out.println(wrapper.getColumnNames());
- System.out.println(wrapper.getColumnTypes());
- while (dataIterator.next()) {
- StringBuilder builder = new StringBuilder();
- for (String columnName : wrapper.getColumnNames()) {
- builder.append(dataIterator.getString(columnName) + " ");
- }
- System.out.println(builder);
- }
- } catch (IoTDBConnectionException | StatementExecutionException e) {
- e.printStackTrace();
- } finally {
- // remember to close data set finally!
- pool.closeResultSet(wrapper);
- }
- });
- }
- }
-}
diff --git a/example/session/src/main/java/org/apache/iotdb/WriteCSVToIoTDB.java b/example/session/src/main/java/org/apache/iotdb/WriteCSVToIoTDB.java
deleted file mode 100644
index 4701e9f..0000000
--- a/example/session/src/main/java/org/apache/iotdb/WriteCSVToIoTDB.java
+++ /dev/null
@@ -1,46 +0,0 @@
-package org.apache.iotdb;
-
-import org.apache.iotdb.rpc.IoTDBConnectionException;
-import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.session.Session;
-import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-
-import java.io.BufferedReader;
-import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
-import java.util.Collections;
-
-public class WriteCSVToIoTDB {
-
- public static final String timeseries = "root.kobelco.trans.03.1090001603.2401604.KOB_0002_00_67";
- public static final String path = "/home/kyy/Documents/kdd/data/" + timeseries + ".csv";
-
- public static void main(String[] args)
- throws IOException, IoTDBConnectionException, StatementExecutionException {
-
- String[] nodes = timeseries.split("\\.");
- String measurements = nodes[nodes.length - 1];
- String device = timeseries.replace("." + measurements, "");
-
- Session session = new Session("127.0.0.1", 6667, "root", "root");
- session.open(false);
-
- File f = new File(path);
- String line = null;
- BufferedReader reader = new BufferedReader(new FileReader(f));
- while ((line = reader.readLine()) != null) {
- String[] split = line.split(",");
- long timestamp = Long.valueOf(split[0]);
- long value = Long.valueOf(split[1]);
- session.insertRecord(
- device,
- timestamp,
- Collections.singletonList(measurements),
- Collections.singletonList(TSDataType.INT64),
- value);
- }
- session.executeNonQueryStatement("flush");
- session.close();
- }
-}
diff --git a/example/session/src/main/java/org/apache/iotdb/mac/QueryFullGameExperimentMAC.java b/example/session/src/main/java/org/apache/iotdb/mac/QueryFullGameExperimentMAC.java
deleted file mode 100644
index 539bfbc..0000000
--- a/example/session/src/main/java/org/apache/iotdb/mac/QueryFullGameExperimentMAC.java
+++ /dev/null
@@ -1,47 +0,0 @@
-// package org.apache.iotdb.mac;
-//
-// 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.tsfile.read.common.RowRecord;
-//
-// import org.apache.thrift.TException;
-//
-// public class QueryFullGameExperimentMAC {
-//
-// private static final String queryFormat =
-// "select %s " + "from %s " + "where time >= %d and time < %d";
-//
-// public static Session session;
-//
-// public static void main(String[] args)
-// throws IoTDBConnectionException, StatementExecutionException, TException {
-// int intervalNum = Integer.parseInt(args[0]);
-// String measurement = "s6";
-// String device = "root.game";
-// session = new Session("127.0.0.1", 6667, "root", "root");
-// session.open(false);
-// SessionDataSet dataSet;
-// long minTime = 0L;
-// long maxTime = 4264605928301L;
-// long interval = (long) Math.ceil((double) (maxTime - minTime) / intervalNum);
-// maxTime = minTime + interval * intervalNum;
-//
-// for (int i = 0; i < intervalNum; i++) {
-// long start = i * interval;
-// long end = (i + 1) * interval;
-// String sql = String.format(queryFormat, measurement, device, start, end);
-// dataSet = session.executeQueryStatement(sql);
-// while (dataSet.hasNext()) {
-// RowRecord r = dataSet.next();
-// }
-// }
-// session.executeNonQueryStatement("clear cache");
-// dataSet = session.executeFinish();
-// String info = dataSet.getFinishResult();
-// System.out.println(info);
-// dataSet.closeOperationHandle();
-// session.close();
-// }
-// }
diff --git a/example/session/src/main/java/org/apache/iotdb/queryExp/QueryFullGame.java b/example/session/src/main/java/org/apache/iotdb/queryExp/QueryBallSpeed.java
similarity index 99%
rename from example/session/src/main/java/org/apache/iotdb/queryExp/QueryFullGame.java
rename to example/session/src/main/java/org/apache/iotdb/queryExp/QueryBallSpeed.java
index a8fb254..6f95a53 100644
--- a/example/session/src/main/java/org/apache/iotdb/queryExp/QueryFullGame.java
+++ b/example/session/src/main/java/org/apache/iotdb/queryExp/QueryBallSpeed.java
@@ -8,7 +8,7 @@ import org.apache.iotdb.tsfile.read.common.RowRecord;
import org.apache.thrift.TException;
-public class QueryFullGame {
+public class QueryBallSpeed {
// * (1) min_time(%s), max_time(%s), first_value(%s), last_value(%s), min_value(%s), max_value(%s)
// => Don't change the sequence of the above six aggregates!
diff --git a/example/session/src/main/java/org/apache/iotdb/queryExp/QueryFullGame_old.java b/example/session/src/main/java/org/apache/iotdb/queryExp/QueryFullGame_old.java
deleted file mode 100644
index a86d45a..0000000
--- a/example/session/src/main/java/org/apache/iotdb/queryExp/QueryFullGame_old.java
+++ /dev/null
@@ -1,104 +0,0 @@
-// package org.apache.iotdb.queryExp;
-//
-// 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.tsfile.read.common.RowRecord;
-//
-// import org.apache.thrift.TException;
-//
-// public class QueryFullGame {
-//
-// // * (1) min_time(%s), max_time(%s), first_value(%s), last_value(%s), min_value(%s),
-// max_value(%s)
-// // => Don't change the sequence of the above six aggregates!
-// // * (2) group by ([tqs,tqe),IntervalLength) => Make sure (tqe-tqs) is divisible by
-// // IntervalLength!
-// // * (3) NOTE the time unit of interval. Update for different datasets!!!!!!!!!!!
-// private static final String queryFormat =
-// "select min_time(%s), max_time(%s), first_value(%s), last_value(%s), min_value(%s),
-// max_value(%s) "
-// + "from %s "
-// + "group by ([%d, %d), %dns)";
-//
-// private static final String queryFormat_UDF =
-// "select M4(%1$s,'tqs'='%3$d','tqe'='%4$d','w'='%5$d') from %2$s where time>=%3$d and
-// time<%4$d";
-//
-// public static Session session;
-//
-// public static void main(String[] args)
-// throws IoTDBConnectionException, StatementExecutionException, TException {
-// // fixed time series path
-// String measurement = "s6";
-// String device = "root.game";
-// // fixed tqs
-// long minTime = 0L;
-// // 实验自变量1：tqe
-// long maxTime = Long.parseLong(args[0]);
-// // 实验自变量2：w数量
-// int intervalNum = Integer.parseInt(args[1]);
-// // 实验自变量3：方法
-// // 1: MAC, 2: MOC, 3: CPV
-// int approach = Integer.parseInt(args[2]);
-// if (approach != 1 && approach != 2 && approach != 3) {
-// throw new TException("Wrong input parameter approach!");
-// }
-// if (approach != 1) {
-// // MOC and CPV sql are the same sql: queryFormat.
-// // Set the server parameter in iotdb-engine.properties: enable_CPV=true for CPV, false for
-// // MOC.
-// if (approach == 2) { // MOC
-// System.out.println(
-// "MAKE SURE you have set the enable_CPV as false in `iotdb-engine.properties` for
-// MOC!");
-// } else { // CPV
-// System.out.println(
-// "MAKE SURE you have set the enable_CPV as true in `iotdb-engine.properties` for
-// CPV!");
-// }
-// }
-//
-// session = new Session("127.0.0.1", 6667, "root", "root");
-// session.open(false);
-// session.setFetchSize(100000); // this is important. Set it big to avoid multiple fetch.
-//
-// long interval = (long) Math.ceil((double) (maxTime - minTime) / intervalNum);
-// maxTime = minTime + interval * intervalNum;
-//
-// String sql;
-// if (approach == 1) { // MAC UDF
-// sql =
-// String.format(queryFormat_UDF, measurement, device, minTime, maxTime, intervalNum); //
-// MAC
-// } else {
-// // MOC and CPV sql use the same sql queryFormat.
-// sql =
-// String.format(
-// queryFormat,
-// measurement,
-// measurement,
-// measurement,
-// measurement,
-// measurement,
-// measurement,
-// device,
-// minTime,
-// maxTime,
-// interval);
-// }
-//
-// SessionDataSet dataSet;
-// dataSet = session.executeQueryStatement(sql);
-// while (dataSet.hasNext()) {
-// RowRecord r = dataSet.next();
-// }
-// session.executeNonQueryStatement("clear cache");
-// dataSet = session.executeFinish();
-// String info = dataSet.getFinishResult();
-// System.out.println(info);
-// dataSet.closeOperationHandle();
-// session.close();
-// }
-// }
diff --git a/example/session/src/main/java/org/apache/iotdb/queryExp/QueryTianyuan.java b/example/session/src/main/java/org/apache/iotdb/queryExp/QueryKOB.java
similarity index 99%
rename from example/session/src/main/java/org/apache/iotdb/queryExp/QueryTianyuan.java
rename to example/session/src/main/java/org/apache/iotdb/queryExp/QueryKOB.java
index 4bf7bb9..e935671 100644
--- a/example/session/src/main/java/org/apache/iotdb/queryExp/QueryTianyuan.java
+++ b/example/session/src/main/java/org/apache/iotdb/queryExp/QueryKOB.java
@@ -8,7 +8,7 @@ import org.apache.iotdb.tsfile.read.common.RowRecord;
import org.apache.thrift.TException;
-public class QueryTianyuan {
+public class QueryKOB {
// * (1) min_time(%s), max_time(%s), first_value(%s), last_value(%s), min_value(%s), max_value(%s)
// => Don't change the sequence of the above six aggregates!
diff --git a/example/session/src/main/java/org/apache/iotdb/queryExp/QueryRecTime.java b/example/session/src/main/java/org/apache/iotdb/queryExp/QueryRcvTime.java
similarity index 98%
rename from example/session/src/main/java/org/apache/iotdb/queryExp/QueryRecTime.java
rename to example/session/src/main/java/org/apache/iotdb/queryExp/QueryRcvTime.java
index 78c225c..ce692e1 100644
--- a/example/session/src/main/java/org/apache/iotdb/queryExp/QueryRecTime.java
+++ b/example/session/src/main/java/org/apache/iotdb/queryExp/QueryRcvTime.java
@@ -8,7 +8,7 @@ import org.apache.iotdb.tsfile.read.common.RowRecord;
import org.apache.thrift.TException;
-public class QueryRecTime {
+public class QueryRcvTime {
// * (1) min_time(%s), max_time(%s), first_value(%s), last_value(%s), min_value(%s), max_value(%s)
// => Don't change the sequence of the above six aggregates!
@@ -28,7 +28,7 @@ public class QueryRecTime {
public static void main(String[] args)
throws IoTDBConnectionException, StatementExecutionException, TException {
// fixed time series path
- String measurement = "RecTime"; // [[update]]
+ String measurement = "RcvTime"; // [[update]]
String device = "root.sg1"; // [[update]]
// used to bound tqs random position
long dataMinTime = 1616194494000L; // [[update]]
diff --git a/example/session/src/main/java/org/apache/iotdb/tools/iotdb-engine-example.properties b/example/session/src/main/java/org/apache/iotdb/tools/iotdb-engine-example.properties
new file mode 100644
index 0000000..2f0d2c9
--- /dev/null
+++ b/example/session/src/main/java/org/apache/iotdb/tools/iotdb-engine-example.properties
@@ -0,0 +1,740 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+
+####################
+### enable CPV
+####################
+enable_CPV=false
+
+####################
+### Web Page Configuration
+####################
+
+# enable_metric_service=false
+
+# metrics_port=8181
+
+# query_cache_size_in_metric=50
+
+####################
+### RPC Configuration
+####################
+
+rpc_address=0.0.0.0
+
+rpc_port=6667
+
+# rpc_thrift_compression_enable=false
+
+# if true, a snappy based compression method will be called before sending data by the network
+# rpc_advanced_compression_enable=false
+
+# rpc_max_concurrent_client_num=65535
+
+# thrift max frame size, 512MB by default
+# thrift_max_frame_size=536870912
+
+# thrift init buffer size
+# thrift_init_buffer_size=1024
+
+####################
+### Write Ahead Log Configuration
+####################
+
+# Is insert ahead log enable
+# enable_wal=true
+
+# Add a switch to drop ouf-of-order data
+# Out-of-order data will impact the aggregation query a lot. Users may not care about discarding some out-of-order data.
+# enable_discard_out_of_order_data=false
+
+# When a certain amount of insert ahead log is reached, it will be flushed to disk
+# It is possible to lose at most flush_wal_threshold operations
+# flush_wal_threshold=10000
+
+# The cycle when insert ahead log is periodically forced to be written to disk(in milliseconds)
+# If force_wal_period_in_ms = 0 it means force insert ahead log to be written to disk after each refreshment
+# Set this parameter to 0 may slow down the ingestion on slow disk.
+# force_wal_period_in_ms=100
+
+####################
+### Directory Configuration
+####################
+
+# system dir
+# If this property is unset, system will save the data in the default relative path directory under the IoTDB folder(i.e., %IOTDB_HOME%/data/system).
+# If it is absolute, system will save the data in exact location it points to.
+# If it is relative, system will save the data in the relative path directory it indicates under the IoTDB folder.
+# For windows platform
+# If its prefix is a drive specifier followed by "\\", or if its prefix is "\\\\", then the path is absolute. Otherwise, it is relative.
+# system_dir=data\\system
+# For Linux platform
+# If its prefix is "/", then the path is absolute. Otherwise, it is relative.
+system_dir=/data3/ruilei/rl/dataSpace/recTime_O_10_10_D_0_0/system
+
+# data dirs
+# If this property is unset, system will save the data in the default relative path directory under the IoTDB folder(i.e., %IOTDB_HOME%/data/data).
+# If it is absolute, system will save the data in exact location it points to.
+# If it is relative, system will save the data in the relative path directory it indicates under the IoTDB folder.
+# Note: If data_dir is assigned an empty string(i.e.,zero-size), it will be handled as a relative path.
+# For windows platform
+# If its prefix is a drive specifier followed by "\\", or if its prefix is "\\\\", then the path is absolute. Otherwise, it is relative.
+# data_dirs=data\\data
+# For Linux platform
+# If its prefix is "/", then the path is absolute. Otherwise, it is relative.
+data_dirs=/data3/ruilei/rl/dataSpace/recTime_O_10_10_D_0_0/data
+
+# mult_dir_strategy
+# The strategy is used to choose a directory from tsfile_dir for the system to store a new tsfile.
+# System provides three strategies to choose from, or user can create his own strategy by extending org.apache.iotdb.db.conf.directories.strategy.DirectoryStrategy.
+# The info of the three strategies are as follows:
+# 1. SequenceStrategy: the system will choose the directory in sequence.
+# 2. MaxDiskUsableSpaceFirstStrategy: the system will choose the directory whose disk has the maximum space.
+# 3. MinFolderOccupiedSpaceFirstStrategy: the system will choose the directory whose folder has the minimum occupied space.
+# 4. RandomOnDiskUsableSpaceStrategy: the system will randomly choose the directory based on usable space of disks. The more usable space, the greater the chance of being chosen;
+# Set SequenceStrategy,MaxDiskUsableSpaceFirstStrategy and MinFolderOccupiedSpaceFirstStrategy to apply the corresponding strategy.
+# If this property is unset, system will use MaxDiskUsableSpaceFirstStrategy as default strategy.
+# For this property, fully-qualified class name (include package name) and simple class name are both acceptable.
+# multi_dir_strategy=MaxDiskUsableSpaceFirstStrategy
+
+
+# wal dir
+# If this property is unset, system will save the data in the default relative path directory under the IoTDB folder(i.e., %IOTDB_HOME%/data).
+# If it is absolute, system will save the data in the exact location it points to.
+# If it is relative, system will save the data in the relative path directory it indicates under the IoTDB folder.
+# Note: If wal_dir is assigned an empty string(i.e.,zero-size), it will be handled as a relative path.
+# For windows platform
+# If its prefix is a drive specifier followed by "\\", or if its prefix is "\\\\", then the path is absolute. Otherwise, it is relative.
+# wal_dir=data\\wal
+# For Linux platform
+# If its prefix is "/", then the path is absolute. Otherwise, it is relative.
+wal_dir=/data3/ruilei/rl/dataSpace/recTime_O_10_10_D_0_0/wal
+
+# TSFile storage file system. Currently, Tsfile are supported to be stored in LOCAL file system or HDFS.
+# tsfile_storage_fs=LOCAL
+
+# If using HDFS, the absolute file path of Hadoop core-site.xml should be configured
+# core_site_path=/etc/hadoop/conf/core-site.xml
+
+# If using HDFS, the absolute file path of Hadoop hdfs-site.xml should be configured
+# hdfs_site_path=/etc/hadoop/conf/hdfs-site.xml
+
+# If using HDFS, hadoop ip can be configured. If there are more than one hdfs_ip, Hadoop HA is used
+# hdfs_ip=localhost
+
+# If using HDFS, hadoop port can be configured
+# hdfs_port=9000
+
+# If there are more than one hdfs_ip, Hadoop HA is used. Below are configuration for HA
+# If using Hadoop HA, nameservices of hdfs can be configured
+# dfs_nameservices=hdfsnamespace
+
+# If using Hadoop HA, namenodes under dfs nameservices can be configured
+# dfs_ha_namenodes=nn1,nn2
+
+# If using Hadoop HA, automatic failover can be enabled or disabled
+# dfs_ha_automatic_failover_enabled=true
+
+# If using Hadoop HA and enabling automatic failover, the proxy provider can be configured
+# dfs_client_failover_proxy_provider=org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider
+
+# If using kerberos to authenticate hdfs, this should be true
+# hdfs_use_kerberos=false
+
+# Full path of kerberos keytab file
+# kerberos_keytab_file_path=/path
+
+# Kerberos pricipal
+# kerberos_principal=your principal
+
+
+####################
+### Storage Engine Configuration
+####################
+
+# Use this value to set timestamp precision as "ms", "us" or "ns".
+# Once the precision is been set, it can not be changed.
+timestamp_precision=ms
+
+# Default TTL for storage groups that are not set TTL by statements, in ms. If not set (default),
+# the TTL will be unlimited.
+# Notice: if this property is changed, previous created storage group which are not set TTL will
+# also be affected. And negative values are accepted, which means you can only insert future
+# data.
+# default_ttl=36000000
+
+# The size of the log buffer in each log node (in bytes). Due to the double buffer mechanism,
+# if WAL is enabled and the size of the inserted plan is greater than one-half of this parameter,
+# then the insert plan will be rejected by WAL.
+# If it sets a value smaller than 0, use the default value 16777216
+# wal_buffer_size=16777216
+
+# When a unSequence TsFile's file size (in byte) exceeds this, the TsFile is forced closed.
+# It may cause memTable size smaller if it is a large value
+unseq_tsfile_size=1073741824
+
+# When a sequence TsFile's file size (in byte) exceeds this, the TsFile is forced closed.
+# It may cause memTable size smaller if it is a large value
+seq_tsfile_size=1073741824
+
+# Size of log buffer in each metadata operation plan(in byte).
+# If the size of a metadata operation plan is larger than this parameter, then it will be rejected by MManager
+# If it sets a value smaller than 0, use the default value 1024*1024
+# mlog_buffer_size=1048576
+
+# When a memTable's size (in byte) exceeds this, the memtable is flushed to disk. The default threshold is 1 GB.
+# memtable_size_threshold=1073741824
+
+# Whether to timed flush sequence tsfiles' memtables.
+# Datatype: boolean
+# enable_timed_flush_seq_memtable=false
+
+# If a memTable's created time is older than current time minus this, the memtable will be flushed to disk.
+# Only check sequence tsfiles' memtables.
+# The default flush interval is 60 * 60 * 1000. (unit: ms)
+# Datatype: long
+# seq_memtable_flush_interval_in_ms=3600000
+
+# The interval to check whether sequence memtables need flushing.
+# The default flush check interval is 10 * 60 * 1000. (unit: ms)
+# Datatype: long
+# seq_memtable_flush_check_interval_in_ms=600000
+
+# Whether to timed flush unsequence tsfiles' memtables.
+# Datatype: boolean
+# enable_timed_flush_unseq_memtable=true
+
+# If a memTable's created time is older than current time minus this, the memtable will be flushed to disk.
+# Only check unsequence tsfiles' memtables.
+# The default flush interval is 60 * 60 * 1000. (unit: ms)
+# Datatype: long
+# unseq_memtable_flush_interval_in_ms=3600000
+
+# The interval to check whether unsequence memtables need flushing.
+# The default flush check interval is 10 * 60 * 1000. (unit: ms)
+# Datatype: long
+# unseq_memtable_flush_check_interval_in_ms=600000
+
+# Whether to timed close tsfiles.
+# Datatype: boolean
+# enable_timed_close_tsfile=true
+
+# If a TsfileProcessor's last working memtable flush time is older than current time minus this and its working memtable is null, the TsfileProcessor will be closed.
+# The default close interval is 60 * 60 * 1000. (unit: ms)
+# Datatype: long
+# close_tsfile_interval_after_flushing_in_ms=3600000
+
+# The interval to check whether tsfiles need closing.
+# The default close check interval is 10 * 60 * 1000. (unit: ms)
+# Datatype: long
+# close_tsfile_check_interval_in_ms=600000
+
+# When the average point number of timeseries in memtable exceeds this, the memtable is flushed to disk. The default threshold is 10000.
+avg_series_point_number_threshold=10000
+
+# How many threads can concurrently flush. When <= 0, use CPU core number.
+# concurrent_flush_thread=0
+
+# How many threads can concurrently query. When <= 0, use CPU core number.
+# concurrent_query_thread=8
+
+# whether take over the memory management by IoTDB rather than JVM when serializing memtable as bytes in memory
+# (i.e., whether use ChunkBufferPool), value true, false
+# chunk_buffer_pool_enable=false
+
+# The amount of data iterate each time in server (the number of data strips, that is, the number of different timestamps.)
+# batch_size=100000
+
+# max size for tag and attribute of one time series
+# the unit is byte
+# tag_attribute_total_size=700
+
+# interval num for tag and attribute records when force flushing to disk
+# When a certain amount of tag and attribute records is reached, they will be force flushed to disk
+# It is possible to lose at most tag_attribute_flush_interval records
+# tag_attribute_flush_interval=1000
+
+# In one insert (one device, one timestamp, multiple measurements),
+# if enable partial insert, one measurement failure will not impact other measurements
+# enable_partial_insert=true
+
+# Whether to enable MTree snapshot. Default false from 0.11.0 on.
+# enable_mtree_snapshot=false
+
+# The least interval line numbers of mlog.txt when creating a checkpoint and saving snapshot of MTree.
+# Only take effect when enable_mtree_snapshot=true. Unit: line numbers
+# mtree_snapshot_interval=100000
+
+# Threshold interval time of MTree modification. Unit: second. Default: 1 hour(3600 seconds)
+# If the last modification time is less than this threshold, MTree snapshot will not be created
+# Only take effect when enable_mtree_snapshot=true.
+# mtree_snapshot_threshold_time=3600
+
+# number of virtual storage groups per user-defined storage group
+# a virtual storage group is the unit of parallelism in memory as all ingestions in one virtual storage group are serialized
+# recommended value is [virtual storage group number] = [CPU core number] / [user-defined storage group number]
+# virtual_storage_group_num = 1
+
+# Level of TimeIndex, which records the start time and end time of TsFileResource. Currently,
+# DEVICE_TIME_INDEX and FILE_TIME_INDEX are supported, and could not be changed after first set.
+# time_index_level=DEVICE_TIME_INDEX
+
+####################
+### Memory Control Configuration
+####################
+
+# Whether to enable memory control
+# enable_mem_control=true
+
+# Memory Allocation Ratio: Write, Read, Schema and Free Memory.
+# The parameter form is a:b:c:d, where a, b, c and d are integers. for example: 1:1:1:1 , 6:2:1:1
+# If you have high level of writing pressure and low level of reading pressure, please adjust it to for example 6:1:1:2
+# write_read_schema_free_memory_proportion=4:3:1:2
+
+# primitive array size (length of each array) in array pool
+# primitive_array_size=32
+
+# Ratio of write memory for invoking flush disk, 0.4 by default
+# If you have extremely high write load (like batch=1000), it can be set lower than the default value like 0.2
+# flush_proportion=0.4
+
+# Ratio of write memory allocated for buffered arrays, 0.6 by default
+# buffered_arrays_memory_proportion=0.6
+
+# Ratio of write memory for rejecting insertion, 0.8 by default
+# If you have extremely high write load (like batch=1000) and the physical memory size is large enough,
+# it can be set higher than the default value like 0.9
+# reject_proportion=0.8
+
+# If memory (in byte) of storage group increased more than this threshold, report to system. The default value is 16MB
+# storage_group_report_threshold=16777216
+
+# allowed max numbers of deduplicated path in one query
+# it's just an advised value, the real limitation will be the smaller one between this and the one we calculated
+# max_deduplicated_path_num=1000
+
+# When an inserting is rejected, waiting period (in ms) to check system again, 50 by default.
+# If the insertion has been rejected and the read load is low, it can be set larger.
+# check_period_when_insert_blocked=50
+
+# When the waiting time (in ms) of an inserting exceeds this, throw an exception. 10000 by default.
+# If the insertion has been rejected and the read load is low, it can be set larger
+# max_waiting_time_when_insert_blocked=10000
+
+# estimated metadata size (in byte) of one timeseries in Mtree
+# estimated_series_size=300
+
+# size of ioTaskQueue. The default value is 10
+# io_task_queue_size_for_flushing=10
+
+####################
+### Upgrade Configurations
+####################
+
+# When there exists old version(0.9.x/v1) data, how many thread will be set up to perform upgrade tasks, 1 by default.
+# Set to 1 when less than or equal to 0.
+# upgrade_thread_num=1
+
+
+####################
+### Query Configurations
+####################
+
+# the default time period that used in fill query, -1 by default means infinite past time, in ms
+# default_fill_interval=-1
+
+# The max executing time of query. unit: ms
+# query_timeout_threshold=60000
+
+####################
+### Merge Configurations
+####################
+# LEVEL_COMPACTION, NO_COMPACTION
+compaction_strategy=NO_COMPACTION
+
+# Works when the compaction_strategy is LEVEL_COMPACTION.
+# Whether to merge unseq files into seq files or not.
+enable_unseq_compaction=false
+
+# Start compaction task at this delay, unit is ms
+# compaction_interval=30000
+
+# Works when the compaction_strategy is LEVEL_COMPACTION.
+# The max seq file num of each level.
+# When the num of files in one level exceeds this,
+# the files in this level will merge to one and put to upper level.
+# seq_file_num_in_each_level=6
+
+# Works when the compaction_strategy is LEVEL_COMPACTION.
+# The max num of seq level.
+# seq_level_num=3
+
+# Works when compaction_strategy is LEVEL_COMPACTION.
+# The max ujseq file num of each level.
+# When the num of files in one level exceeds this,
+# the files in this level will merge to one and put to upper level.
+# unseq_file_num_in_each_level=10
+
+# Works when the compaction_strategy is LEVEL_COMPACTION.
+# The max num of unseq level.
+# unseq_level_num=1
+
+# Works when compaction_strategy is LEVEL_COMPACTION.
+# The max open file num in each unseq compaction task.
+# We use the unseq file num as the open file num
+# This parameters have to be much smaller than the permitted max open file num of each process controlled by operator system(65535 in most system)
+# Datatype: int
+# max_select_unseq_file_num_in_each_unseq_compaction=2000
+
+# Works when the compaction_strategy is LEVEL_COMPACTION.
+# When the average point number of chunks in the target file reaches this, merge the file to the top level.
+# During a merge, if a chunk with less number of points than this parameter, the chunk will be
+# merged with its succeeding chunks even if it is not overflowed, until the merged chunks reach
+# this threshold and the new chunk will be flushed.
+# When less than 0, this mechanism is disabled.
+# merge_chunk_point_number=100000
+
+# Works when the compaction_strategy is LEVEL_COMPACTION.
+# When point number of a page reaches this, use "append merge" instead of "deserialize merge".
+# merge_page_point_number=100
+
+# How many thread will be used to perform merge task
+# Datatype: int
+# merge_thread_num=1
+
+# How many threads will be set up to perform unseq merge chunk sub-tasks, 4 by default.
+# Set to 1 when less than or equal to 0.
+# merge_chunk_subthread_num=4
+
+# If one merge file selection runs for more than this time, it will be ended and its current
+# selection will be used as final selection. Unit: millis.
+# When < 0, it means time is unbounded.
+# merge_fileSelection_time_budget=30000
+
+# How much memory may be used in ONE merge task (in byte), 10% of maximum JVM memory by default.
+# This is only a rough estimation, starting from a relatively small value to avoid OOM.
+# Each new merge thread may take such memory, so merge_thread_num * merge_memory_budget is the
+# total memory estimation of merge.
+# merge_memory_budget=2147483648
+
+# When set to true, if some crashed merges are detected during system rebooting, such merges will
+# be continued, otherwise, the unfinished parts of such merges will not be continued while the
+# finished parts still remains as they are.
+# If you are feeling the rebooting is too slow, set this to false, false by default
+# continue_merge_after_reboot=false
+
+# When set to true, all unseq merges becomes full merge (the whole SeqFiles are re-written despite how
+# much they are overflowed). This may increase merge overhead depending on how much the SeqFiles
+# are overflowed.
+# force_full_merge=true
+
+# How many threads will be set up to perform compaction, 10 by default.
+# Set to 1 when less than or equal to 0.
+# compaction_thread_num=10
+
+# The limit of write throughput merge can reach per second
+# merge_write_throughput_mb_per_sec=8
+
+####################
+### Metadata Cache Configuration
+####################
+
+# whether to cache meta data(ChunkMetadata and TimeSeriesMetadata) or not.
+# meta_data_cache_enable=true
+# Read memory Allocation Ratio: ChunkCache, TimeSeriesMetadataCache, memory used for constructing QueryDataSet and Free Memory Used in Query.
+# The parameter form is a:b:c:d, where a, b, c and d are integers. for example: 1:1:1:1 , 1:2:3:4
+# chunk_timeseriesmeta_free_memory_proportion=1:2:3:4
+
+# cache size for MManager.
+# This cache is used to improve insert speed where all path check and TSDataType will be cached in MManager with corresponding Path.
+# metadata_node_cache_size=300000
+
+####################
+### LAST Cache Configuration
+####################
+
+# Whether to enable LAST cache
+# enable_last_cache=true
+
+####################
+### Statistics Monitor configuration
+####################
+
+# Set enable_stat_monitor true(or false) to enable(or disable) the StatMonitor that stores statistics info.
+# enable_stat_monitor=false
+
+# Set enable_monitor_series_write true (or false) to enable (or disable) the writing monitor time series
+# enable_monitor_series_write=false
+
+####################
+### WAL Direct Buffer Pool Configuration
+####################
+# the interval to trim the wal pool
+# wal_pool_trim_interval_ms=10000
+
+# the max number of wal bytebuffer can be allocated for each time partition, if there is no unseq data you can set it to 4.
+# it should be an even number
+# max_wal_bytebuffer_num_for_each_partition=6
+
+####################
+### External sort Configuration
+####################
+# Is external sort enable
+# enable_external_sort=true
+
+# The maximum number of simultaneous chunk reading for a single time series.
+# If the num of simultaneous chunk reading is greater than external_sort_threshold, external sorting is used.
+# When external_sort_threshold increases, the number of chunks sorted at the same time in memory may increase and this will occupy more memory.
+# When external_sort_threshold decreases, triggering external sorting will increase the time-consuming.
+# external_sort_threshold=1000
+
+
+####################
+### Sync Server Configuration
+####################
+
+# Whether to open the sync_server_port for receiving data from sync client, the default is closed
+# is_sync_enable=false
+
+# Sync server port to listen
+# sync_server_port=5555
+
+# White IP list of Sync client.
+# Please use the form of network segment to present the range of IP, for example: 192.168.0.0/16
+# If there are more than one IP segment, please separate them by commas
+# The default is to allow all IP to sync
+# ip_white_list=0.0.0.0/0
+
+####################
+### performance statistic configuration
+####################
+
+# Is stat performance of sub-module enable
+# enable_performance_stat=false
+# The interval of display statistic result in ms.
+# performance_stat_display_interval=60000
+# The memory used for performance_stat in kb.
+# performance_stat_memory_in_kb=20
+# Is performance tracing enable
+# enable_performance_tracing=false
+
+# Uncomment following fields to configure the tracing root directory.
+# For Window platform, the index is as follows:
+# tracing_dir=data\\tracing
+# For Linux platform
+# If its prefix is "/", then the path is absolute. Otherwise, it is relative.
+# tracing_dir=data/tracing
+
+####################
+### Configurations for watermark module
+####################
+# watermark_module_opened=false
+# watermark_secret_key=IoTDB*2019@Beijing
+# watermark_bit_string=100101110100
+# watermark_method=GroupBasedLSBMethod(embed_row_cycle=2,embed_lsb_num=5)
+
+
+####################
+### Configurations for creating schema automatically
+####################
+
+# Whether creating schema automatically is enabled
+# enable_auto_create_schema=true
+
+# Storage group level when creating schema automatically is enabled
+# e.g. root.sg0.d1.s2
+# we will set root.sg0 as the storage group if storage group level is 1
+# default_storage_group_level=1
+
+# ALL data types: BOOLEAN, INT32, INT64, FLOAT, DOUBLE, TEXT
+
+# register time series as which type when receiving boolean string "true" or "false"
+# boolean_string_infer_type=BOOLEAN
+
+# register time series as which type when receiving an integer string "67"
+# integer_string_infer_type=FLOAT
+
+# register time series as which type when receiving an integer string and using float may lose precision
+# num > 2 ^ 24
+# long_string_infer_type=DOUBLE
+
+# register time series as which type when receiving a floating number string "6.7"
+# floating_string_infer_type=FLOAT
+
+# register time series as which type when receiving the Literal NaN. Values can be DOUBLE, FLOAT or TEXT
+# nan_string_infer_type=DOUBLE
+
+
+# BOOLEAN encoding when creating schema automatically is enabled
+# default_boolean_encoding=RLE
+
+# INT32 encoding when creating schema automatically is enabled
+# default_int32_encoding=RLE
+
+# INT64 encoding when creating schema automatically is enabled
+# default_int64_encoding=RLE
+
+# FLOAT encoding when creating schema automatically is enabled
+# default_float_encoding=GORILLA
+
+# DOUBLE encoding when creating schema automatically is enabled
+# default_double_encoding=GORILLA
+
+# TEXT encoding when creating schema automatically is enabled
+# default_text_encoding=PLAIN
+
+####################
+### Configurations for tsfile-format
+####################
+
+# group_size_in_byte=134217728
+
+# The memory size for each series writer to pack page, default value is 64KB
+page_size_in_byte=1073741824
+
+# The maximum number of data points in a page, default 1024*1024
+# max_number_of_points_in_page=1048576
+
+# Data type configuration
+# Data type for input timestamp, supports INT32 or INT64
+# time_series_data_type=INT64
+
+# Max size limitation of input string
+# max_string_length=128
+
+# Floating-point precision
+# float_precision=2
+
+# Encoder configuration
+# Encoder of time series, supports TS_2DIFF, PLAIN and RLE(run-length encoding), REGULAR and default value is TS_2DIFF
+# time_encoder=TS_2DIFF
+
+# Encoder of value series. default value is PLAIN.
+# For int, long data type, also supports TS_2DIFF and RLE(run-length encoding) and GORILLA.
+# For float, double data type, also supports TS_2DIFF, RLE(run-length encoding) and GORILLA.
+# For text data type, only supports PLAIN.
+# value_encoder=PLAIN
+
+# Compression configuration
+# Data compression method, supports UNCOMPRESSED, SNAPPY or LZ4. Default value is SNAPPY
+# compressor=SNAPPY
+
+# Maximum degree of a metadataIndex node, default value is 256
+# max_degree_of_index_node=256
+
+# time interval in minute for calculating query frequency
+# frequency_interval_in_minute=1
+
+# time cost(ms) threshold for slow query
+# slow_query_threshold=5000
+
+####################
+### MQTT Broker Configuration
+####################
+
+# whether to enable the mqtt service.
+# enable_mqtt_service=false
+
+# the mqtt service binding host.
+# mqtt_host=0.0.0.0
+
+# the mqtt service binding port.
+# mqtt_port=1883
+
+# the handler pool size for handing the mqtt messages.
+# mqtt_handler_pool_size=1
+
+# the mqtt message payload formatter.
+# mqtt_payload_formatter=json
+
+# max length of mqtt message in byte
+# mqtt_max_message_size=1048576
+
+####################
+### Authorization Configuration
+####################
+
+#which class to serve for authorization. By default, it is LocalFileAuthorizer.
+#Another choice is org.apache.iotdb.db.auth.authorizer.OpenIdAuthorizer
+# authorizer_provider_class=org.apache.iotdb.db.auth.authorizer.LocalFileAuthorizer
+
+
+#If OpenIdAuthorizer is enabled, then openID_url must be set.
+
+#openID_url=
+
+####################
+### UDF Query Configuration
+####################
+
+# Used to estimate the memory usage of text fields in a UDF query.
+# It is recommended to set this value to be slightly larger than the average length of all text
+# records.
+# udf_initial_byte_array_length_for_memory_control=48
+
+# How much memory may be used in ONE UDF query (in MB).
+# The upper limit is 20% of allocated memory for read.
+# udf_memory_budget_in_mb=30.0
+
+# UDF memory allocation ratio.
+# The parameter form is a:b:c, where a, b, and c are integers.
+# udf_reader_transformer_collector_memory_proportion=1:1:1
+
+# Uncomment following fields to configure the udf root directory.
+# For Window platform, the index is as follows:
+# udf_root_dir=ext\\udf
+# For Linux platform
+# If its prefix is "/", then the path is absolute. Otherwise, it is relative.
+# udf_root_dir=ext/udf
+
+
+# Uncomment following fields to configure the index root directory.
+# For Window platform, the index is as follows:
+# index_root_dir=data\\index
+# For Linux platform
+# If its prefix is "/", then the path is absolute. Otherwise, it is relative.
+# index_root_dir=data/index
+
+# Is index enable
+# enable_index=false
+
+# How many threads can concurrently build index. When <= 0, use CPU core number.
+# concurrent_index_build_thread=0
+
+# the default size of sliding window used for the subsequence matching in index framework
+# default_index_window_range=10
+
+# buffer parameter for index processor.
+# index_buffer_size=134217728
+
+# whether enable data partition. If disabled, all data belongs to partition 0
+# enable_partition=false
+
+# time range for partitioning data inside each storage group, the unit is second
+# partition_interval=604800
+
+# concurrent_writing_time_partition=500
+
+# admin username, default is root
+# Datatype: string
+# admin_name=root
+
+# admin password, default is root
+# Datatype: string
+# admin_password=root
diff --git a/example/session/src/main/java/org/apache/iotdb/tools/query_experiment.sh b/example/session/src/main/java/org/apache/iotdb/tools/query_experiment.sh
new file mode 100644
index 0000000..9c9df3a
--- /dev/null
+++ b/example/session/src/main/java/org/apache/iotdb/tools/query_experiment.sh
@@ -0,0 +1,12 @@
+#!/bin/bash
+echo 3 | sudo tee /proc/sys/vm/drop_caches
+cd /data3/ruilei/rl/iotdb-server-0.12.4/sbin
+a=5
+for((i=0;i<a;i++)) do
+ ./start-server.sh &
+ sleep 3s
+ java -jar /data3/ruilei/rl/BallSpeed_testspace/QueryBallSpeed-0.12.4.jar $1 $2 $3
+ ./stop-server.sh
+ echo 3 | sudo tee /proc/sys/vm/drop_caches
+ sleep 3s
+done
diff --git a/example/session/src/main/java/org/apache/iotdb/tools/tool.sh b/example/session/src/main/java/org/apache/iotdb/tools/tool.sh
new file mode 100644
index 0000000..86b2274
--- /dev/null
+++ b/example/session/src/main/java/org/apache/iotdb/tools/tool.sh
@@ -0,0 +1,12 @@
+#!/bin/bash
+
+############################
+#script function
+############################
+setProperty(){
+ awk -v pat="^$1=" -v value="$1=$2" '{ if ($0 ~ pat) print value; else print $0; }' $3 > $3.tmp
+ mv $3.tmp $3
+ }
+############################
+### usage: setProperty $key $value $filename
+setProperty $1 $2 $3
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/ExtractFullGameData.java b/example/session/src/main/java/org/apache/iotdb/writeData/ExtractBallSpeedData.java
similarity index 92%
rename from example/session/src/main/java/org/apache/iotdb/writeData/ExtractFullGameData.java
rename to example/session/src/main/java/org/apache/iotdb/writeData/ExtractBallSpeedData.java
index aa7e6c5..72ccb94 100644
--- a/example/session/src/main/java/org/apache/iotdb/writeData/ExtractFullGameData.java
+++ b/example/session/src/main/java/org/apache/iotdb/writeData/ExtractBallSpeedData.java
@@ -7,9 +7,8 @@ import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
-// java ExtractFullGameData /data3/raw_data/data/full-game full-game-sid8-10min 1 5 8 2000000
-// 3200000
-public class ExtractFullGameData {
+// java ExtractBallSpeedData /data3/raw_data/data/full-game BallSpeed.csv 1 5 8 2000000 3200000
+public class ExtractBallSpeedData {
// sid, ts, x, y, z, |v|, |a|, vx, vy, vz, ax, ay, az
public static void main(String[] args) throws IOException {
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/ExtractTianyuan.java b/example/session/src/main/java/org/apache/iotdb/writeData/ExtractKOBData.java
similarity index 88%
rename from example/session/src/main/java/org/apache/iotdb/writeData/ExtractTianyuan.java
rename to example/session/src/main/java/org/apache/iotdb/writeData/ExtractKOBData.java
index 03ad103..02fceef 100644
--- a/example/session/src/main/java/org/apache/iotdb/writeData/ExtractTianyuan.java
+++ b/example/session/src/main/java/org/apache/iotdb/writeData/ExtractKOBData.java
@@ -7,7 +7,9 @@ import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
-public class ExtractTianyuan {
+// java ExtractTianyuan /data3/raw_data/data/tianyuan/root.kobelco.trans.03.1090001603.2401604.KOB_0002_00_67.csv
+// KOB.csv 0 1
+public class ExtractKOBData {
public static void main(String[] args) throws IOException {
String inPath = args[0];
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/ExtractDebs2012Data.java b/example/session/src/main/java/org/apache/iotdb/writeData/ExtractMF03Data.java
similarity index 93%
rename from example/session/src/main/java/org/apache/iotdb/writeData/ExtractDebs2012Data.java
rename to example/session/src/main/java/org/apache/iotdb/writeData/ExtractMF03Data.java
index 54cbfa7..57e1f3c 100644
--- a/example/session/src/main/java/org/apache/iotdb/writeData/ExtractDebs2012Data.java
+++ b/example/session/src/main/java/org/apache/iotdb/writeData/ExtractMF03Data.java
@@ -11,15 +11,11 @@ import java.time.ZonedDateTime;
import java.time.format.DateTimeFormatter;
import java.time.format.DateTimeParseException;
-public class ExtractDebs2012Data {
+public class ExtractMF03Data {
- // java ExtractDebs2012Data /data3/raw_data/data/debs2012/allData.txt mf03-3h.csv 0 4
+ // java ExtractMF03Data /data3/raw_data/data/debs2012/allData.txt MF03.csv 0 4
// 1329955200000000000 1329966000000000000
public static void main(String[] args) throws IOException {
- // String tmp = "2012-03-20T06:53:51.4554819+00:00";
- // long timestamp = getInstantWithPrecision(tmp, "ns");
- // System.out.println(timestamp);
-
String inPath = args[0];
String outPath = args[1];
int timeIdx = Integer.parseInt(args[2]); // 0
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/ExtractRecTimeData.java b/example/session/src/main/java/org/apache/iotdb/writeData/ExtractRcvTimeData.java
similarity index 89%
rename from example/session/src/main/java/org/apache/iotdb/writeData/ExtractRecTimeData.java
rename to example/session/src/main/java/org/apache/iotdb/writeData/ExtractRcvTimeData.java
index 9fe43d1..03dd4b2 100644
--- a/example/session/src/main/java/org/apache/iotdb/writeData/ExtractRecTimeData.java
+++ b/example/session/src/main/java/org/apache/iotdb/writeData/ExtractRcvTimeData.java
@@ -11,15 +11,10 @@ import java.time.ZonedDateTime;
import java.time.format.DateTimeFormatter;
import java.time.format.DateTimeParseException;
-public class ExtractRecTimeData {
+public class ExtractRcvTimeData {
- // java D:\pythonPlotDoNotDeleteIt\drawRawData\RecTime\dump0.csv
- // D:\pythonPlotDoNotDeleteIt\drawRawData\RecTime\dump1.csv 0 1 0 1644144767000
+ // java D:\RcvTime\dump0.csv RcvTime.csv 0 1 0 1644144767000
public static void main(String[] args) throws IOException {
- // String tmp = "2021-03-20T06:54:54.000+08:00";
- // long timestamp = getInstantWithPrecision(tmp, "ms");
- // System.out.println(timestamp);
-
String inPath = args[0];
String outPath = args[1];
int timeIdx = Integer.parseInt(args[2]); // 0
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/OverlapFullGame.java b/example/session/src/main/java/org/apache/iotdb/writeData/OverlapGenerator.java
similarity index 90%
rename from example/session/src/main/java/org/apache/iotdb/writeData/OverlapFullGame.java
rename to example/session/src/main/java/org/apache/iotdb/writeData/OverlapGenerator.java
index 313b581..8465ecd 100644
--- a/example/session/src/main/java/org/apache/iotdb/writeData/OverlapFullGame.java
+++ b/example/session/src/main/java/org/apache/iotdb/writeData/OverlapGenerator.java
@@ -12,14 +12,10 @@ import java.util.List;
import java.util.Random;
/**
- * 每次快要写到10000个点（chunk size）还剩下OD%个点的时候，OP%的概率决定要不要乱序. 如果要乱序，
- * 方法是剩下的这OD%个点，和接下来再OD%个点，合在一起2*OD%个点随机打乱然后再写。 0<=OP<=100 0<OD<=50.
- *
- * <p>(1) WriteFullGameToIoTDB. (2) java ExtractFullGameData /data3/raw_data/data/full-game
- * full-game-small 1 5 495760. (3) java WriteOverlapChunks D:\exp\full-game-small
- * D:\exp\full-game-small-OP90-OD50 0 1 90 50.
+ * 每次快要写到10000个点（chunk size）还剩下OD%个点的时候，OP%的概率决定要不要乱序. 如果要乱序， 方法是剩下的这OD%个点，和接下来再OD%个点，合在一起2*OD%个点随机打乱然后再写。
+ * 0<=OP<=100 0<OD<=50.
*/
-public class OverlapFullGame {
+public class OverlapGenerator {
public static void main(String[] args) throws IOException {
// default
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGame.java b/example/session/src/main/java/org/apache/iotdb/writeData/WriteBallSpeed.java
similarity index 99%
rename from example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGame.java
rename to example/session/src/main/java/org/apache/iotdb/writeData/WriteBallSpeed.java
index ad0e863..0257be7 100644
--- a/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGame.java
+++ b/example/session/src/main/java/org/apache/iotdb/writeData/WriteBallSpeed.java
@@ -13,8 +13,7 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
-public class WriteFullGame {
-
+public class WriteBallSpeed {
/** Before writing data, make sure check the server parameter configurations. */
public static void main(String[] args)
throws IoTDBConnectionException, StatementExecutionException, IOException {
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGameDisorderedToIoTDB.java b/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGameDisorderedToIoTDB.java
deleted file mode 100644
index d82416e..0000000
--- a/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGameDisorderedToIoTDB.java
+++ /dev/null
@@ -1,52 +0,0 @@
-// package org.apache.iotdb.writeData;
-//
-// import org.apache.iotdb.rpc.IoTDBConnectionException;
-// import org.apache.iotdb.rpc.StatementExecutionException;
-// import org.apache.iotdb.session.Session;
-// import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-//
-// import java.io.BufferedReader;
-// import java.io.File;
-// import java.io.FileReader;
-// import java.io.IOException;
-// import java.util.Collections;
-//
-// public class WriteFullGameDisorderedToIoTDB {
-//
-// public static void main(String[] args)
-// throws IOException, IoTDBConnectionException, StatementExecutionException {
-//
-// String path = args[0];
-//
-// String measurements = "s6";
-// String device = "root.game";
-//
-// Session session = new Session("127.0.0.1", 6667, "root", "root");
-// session.open(false);
-//
-// long minTime = -1;
-// File f = new File(path);
-// String line = null;
-// BufferedReader reader = new BufferedReader(new FileReader(f));
-// while ((line = reader.readLine()) != null) {
-// String[] split = line.split(",");
-// long timestamp = Long.valueOf(split[3]);
-// if (minTime == -1) {
-// minTime = timestamp;
-// timestamp = 0;
-// } else {
-// timestamp = timestamp - minTime;
-// }
-// timestamp = (long) (timestamp / 1000); // turn to ns
-// long value = Long.valueOf(split[7]);
-// session.insertRecord(
-// device,
-// timestamp,
-// Collections.singletonList(measurements),
-// Collections.singletonList(TSDataType.INT64),
-// value);
-// }
-// session.executeNonQueryStatement("flush");
-// session.close();
-// }
-// }
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGameDisorderedWithDeletes.java b/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGameDisorderedWithDeletes.java
deleted file mode 100644
index 1baa587..0000000
--- a/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGameDisorderedWithDeletes.java
+++ /dev/null
@@ -1,74 +0,0 @@
-// package org.apache.iotdb.writeData;
-//
-// import org.apache.iotdb.rpc.IoTDBConnectionException;
-// import org.apache.iotdb.rpc.StatementExecutionException;
-// import org.apache.iotdb.session.Session;
-// import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-//
-// import java.io.BufferedReader;
-// import java.io.File;
-// import java.io.FileReader;
-// import java.io.IOException;
-// import java.util.ArrayList;
-// import java.util.Collections;
-// import java.util.List;
-// import java.util.Random;
-//
-// public class WriteFullGameDisorderedWithDeletes {
-//
-// /** Before writing data, make sure check the server parameter configurations. */
-// public static void main(String[] args)
-// throws IoTDBConnectionException, StatementExecutionException, IOException {
-// String measurements = "s6";
-// String device = "root.game";
-// List<String> deletePaths = new ArrayList<>();
-// deletePaths.add(device + "." + measurements);
-//
-// // 实验自变量1：乱序数据源
-// String filePath = args[0];
-// // 实验自变量2：每隔deleteFreq时间（本实验时间单位ms）就执行一次删除
-// long deleteFreq = Long.parseLong(args[1]); // 0 means no deletes
-// // 实验自变量3：每次删除的时间长度
-// long deleteLen = Long.parseLong(args[2]);
-//
-// Session session = new Session("127.0.0.1", 6667, "root", "root");
-// session.open(false);
-//
-// long minTime = -1;
-// File f = new File(filePath);
-// String line = null;
-// BufferedReader reader = new BufferedReader(new FileReader(f));
-// while ((line = reader.readLine()) != null) {
-// String[] split = line.split(",");
-// long timestamp = Long.valueOf(split[3]);
-// if (minTime == -1) {
-// minTime = timestamp;
-// timestamp = 0;
-// } else {
-// timestamp = timestamp - minTime;
-// }
-// timestamp = (long) (timestamp / 1000); // turn to ns. original time unit is ps. IoTDB only
-// ns.
-//
-// if (deleteFreq != 0 && timestamp != 0 && timestamp % deleteFreq == 0) {
-// // [timestamp-deleteFreq, timestamp-1]内随机取一个删除时间起点
-// long min = timestamp - deleteFreq;
-// long max = timestamp - 1;
-// long deleteStartTime = min + (((long) (new Random().nextDouble() * (max - min))));
-// long deleteEndTime = deleteStartTime + deleteLen - 1;
-// session.deleteData(deletePaths, deleteStartTime, deleteEndTime);
-// }
-//
-// long value = Long.valueOf(split[7]);
-// session.insertRecord(
-// device,
-// timestamp,
-// Collections.singletonList(measurements),
-// Collections.singletonList(TSDataType.INT64),
-// value);
-// }
-//
-// session.executeNonQueryStatement("flush");
-// session.close();
-// }
-// }
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGameToIoTDB.java b/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGameToIoTDB.java
deleted file mode 100644
index 4e73065..0000000
--- a/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGameToIoTDB.java
+++ /dev/null
@@ -1,54 +0,0 @@
-// package org.apache.iotdb.writeData;
-//
-// import org.apache.iotdb.rpc.IoTDBConnectionException;
-// import org.apache.iotdb.rpc.StatementExecutionException;
-// import org.apache.iotdb.session.Session;
-// import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-//
-// import java.io.BufferedReader;
-// import java.io.File;
-// import java.io.FileReader;
-// import java.io.IOException;
-// import java.util.Collections;
-//
-// public class WriteFullGameToIoTDB {
-//
-// public static void main(String[] args)
-// throws IOException, IoTDBConnectionException, StatementExecutionException {
-//
-// // String path = args[0];
-// String path = "/home/kyy/Documents/kdd/data/full-game.csv";
-// String measurements = "s6";
-//
-// String device = "root.game";
-//
-// Session session = new Session("127.0.0.1", 6667, "root", "root");
-// session.open(false);
-//
-// long minTime = -1;
-//
-// File f = new File(path);
-// String line = null;
-// BufferedReader reader = new BufferedReader(new FileReader(f));
-// while ((line = reader.readLine()) != null) {
-// String[] split = line.split(",");
-// long timestamp = Long.valueOf(split[1]);
-// if (minTime == -1) {
-// minTime = timestamp;
-// timestamp = 0;
-// } else {
-// timestamp = timestamp - minTime;
-// }
-// timestamp = (long) (timestamp / 1000);
-// long value = Long.valueOf(split[5]);
-// session.insertRecord(
-// device,
-// timestamp,
-// Collections.singletonList(measurements),
-// Collections.singletonList(TSDataType.INT64),
-// value);
-// }
-// session.executeNonQueryStatement("flush");
-// session.close();
-// }
-// }
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGame_old.java b/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGame_old.java
deleted file mode 100644
index d2ea08a..0000000
--- a/example/session/src/main/java/org/apache/iotdb/writeData/WriteFullGame_old.java
+++ /dev/null
@@ -1,98 +0,0 @@
-package org.apache.iotdb.writeData;
-
-import org.apache.iotdb.rpc.IoTDBConnectionException;
-import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.session.Session;
-import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-
-import java.io.BufferedReader;
-import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Random;
-
-public class WriteFullGame_old {
-
- /** Before writing data, make sure check the server parameter configurations. */
- public static void main(String[] args)
- throws IoTDBConnectionException, StatementExecutionException, IOException {
- String measurements = "s6";
- String device = "root.game";
-
- List<String> deletePaths = new ArrayList<>();
- deletePaths.add(device + "." + measurements);
-
- // 实验自变量1：乱序数据源
- String filePath = args[0];
- // 实验自变量2：每隔deleteFreq时间（本实验时间单位ms）就执行一次删除
- long deleteFreq = Long.parseLong(args[1]); // 0 means no deletes
- // 实验自变量3：每次删除的时间长度
- long deleteLen = Long.parseLong(args[2]);
- // 参数4：时间戳idx，从0开始
- int timeIdx = Integer.parseInt(args[3]);
- // 参数5：值idx，从0开始
- int valueIdx = Integer.parseInt(args[4]);
-
- TSDataType tsDataType = TSDataType.INT64;
-
- Session session = new Session("127.0.0.1", 6667, "root", "root");
- session.open(false);
-
- // this is to make all following inserts unseq chunks
- session.insertRecord(
- device,
- System.nanoTime(), // NOTE UPDATE TIME DATATYPE!
- Collections.singletonList(measurements),
- Collections.singletonList(tsDataType), // NOTE UPDATE VALUE DATATYPE!
- 0L); // NOTE UPDATE VALUE DATATYPE!!!
- session.executeNonQueryStatement("flush");
-
- long minTime = -1;
- File f = new File(filePath);
- String line = null;
- BufferedReader reader = new BufferedReader(new FileReader(f));
- int lastDeleteIdx = -1;
- while ((line = reader.readLine()) != null) {
- String[] split = line.split(",");
- long timestamp = Long.parseLong(split[timeIdx]);
- if (minTime == -1) {
- minTime = timestamp; // assume first timestamp is never disordered. is global minimal.
- timestamp = 0;
- } else {
- timestamp = timestamp - minTime;
- }
- timestamp = (long) (timestamp / 1000); // turn to ns. original time unit is ps. IoTDB only ns.
-
- if (deleteFreq != 0) {
- int idx = (int) Math.floor(timestamp * 1.0 / deleteFreq);
- // System.out.println(timestamp + "," + deleteFreq + "," + idx);
- if (idx > 0 && idx != lastDeleteIdx) {
- lastDeleteIdx = idx;
- // [timestamp-deleteFreq, timestamp-1]内随机取一个删除时间起点
- long min = timestamp - deleteFreq;
- long max = timestamp - 1;
- long deleteStartTime = min + (((long) (new Random().nextDouble() * (max - min))));
- long deleteEndTime = deleteStartTime + deleteLen - 1;
- session.deleteData(deletePaths, deleteStartTime, deleteEndTime);
-
- // System.out.println("[[[[delete]]]]]" + deleteStartTime + "," + deleteEndTime);
-
- }
- }
-
- long value = Long.parseLong(split[valueIdx]);
- session.insertRecord(
- device,
- timestamp,
- Collections.singletonList(measurements),
- Collections.singletonList(tsDataType),
- value);
- }
-
- session.executeNonQueryStatement("flush");
- session.close();
- }
-}
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/WriteTianyuan.java b/example/session/src/main/java/org/apache/iotdb/writeData/WriteKOB.java
similarity index 97%
rename from example/session/src/main/java/org/apache/iotdb/writeData/WriteTianyuan.java
rename to example/session/src/main/java/org/apache/iotdb/writeData/WriteKOB.java
index 8c4dff3..0f29d56 100644
--- a/example/session/src/main/java/org/apache/iotdb/writeData/WriteTianyuan.java
+++ b/example/session/src/main/java/org/apache/iotdb/writeData/WriteKOB.java
@@ -13,13 +13,14 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
-public class WriteTianyuan {
+public class WriteKOB {
/** Before writing data, make sure check the server parameter configurations. */
public static void main(String[] args)
throws IoTDBConnectionException, StatementExecutionException, IOException {
String measurement = "KOB_0002_00_67"; // [[update]]
String device = "root.kobelco.trans.03.1090001603.2401604"; // [[update]]
+ long chunkAvgTimeLen = 55826201L;
// 实验自变量1：乱序数据源
String filePath = args[0];
@@ -31,8 +32,6 @@ public class WriteTianyuan {
int timeIdx = Integer.parseInt(args[3]);
// 参数5：值idx，从0开始
int valueIdx = Integer.parseInt(args[4]);
- // 参数6：chunkAvgTimeLen
- long chunkAvgTimeLen = Long.parseLong(args[5]);
if (deletePercentage < 0 || deletePercentage > 100) {
throw new IOException("WRONG deletePercentage!");
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/WriteMF03.java b/example/session/src/main/java/org/apache/iotdb/writeData/WriteMF03.java
index 0322554..657934c 100644
--- a/example/session/src/main/java/org/apache/iotdb/writeData/WriteMF03.java
+++ b/example/session/src/main/java/org/apache/iotdb/writeData/WriteMF03.java
@@ -13,15 +13,13 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
-// java -jar /data3/ruilei/rl/mf03_testspace/WriteMF03-0.12.4.jar
-// /data3/raw_data/rl/debs2012/mf03-3h-O_10_10 0 0 0 1 0
public class WriteMF03 {
-
/** Before writing data, make sure check the server parameter configurations. */
public static void main(String[] args)
throws IoTDBConnectionException, StatementExecutionException, IOException {
String measurement = "mf03"; // [[update]]
String device = "root.debs2012"; // [[update]]
+ long chunkAvgTimeLen = 102213719111L; // ns [[update]]
// 实验自变量1：乱序数据源
String filePath = args[0];
@@ -33,8 +31,6 @@ public class WriteMF03 {
int timeIdx = Integer.parseInt(args[3]);
// 参数5：值idx，从0开始
int valueIdx = Integer.parseInt(args[4]);
- // 参数6：chunkAvgTimeLen
- long chunkAvgTimeLen = Long.parseLong(args[5]);
if (deletePercentage < 0 || deletePercentage > 100) {
throw new IOException("WRONG deletePercentage!");
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/WriteRecTime.java b/example/session/src/main/java/org/apache/iotdb/writeData/WriteRcvTime.java
similarity index 96%
rename from example/session/src/main/java/org/apache/iotdb/writeData/WriteRecTime.java
rename to example/session/src/main/java/org/apache/iotdb/writeData/WriteRcvTime.java
index b49224b..c7099b2 100644
--- a/example/session/src/main/java/org/apache/iotdb/writeData/WriteRecTime.java
+++ b/example/session/src/main/java/org/apache/iotdb/writeData/WriteRcvTime.java
@@ -13,13 +13,14 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
-public class WriteRecTime {
+public class WriteRcvTime {
/** Before writing data, make sure check the server parameter configurations. */
public static void main(String[] args)
throws IoTDBConnectionException, StatementExecutionException, IOException {
- String measurement = "RecTime"; // [[update]]
+ String measurement = "RcvTime"; // [[update]]
String device = "root.sg1"; // [[update]]
+ long chunkAvgTimeLen = 203613320L;
// 实验自变量1：乱序数据源
String filePath = args[0];
@@ -31,8 +32,6 @@ public class WriteRecTime {
int timeIdx = Integer.parseInt(args[3]);
// 参数5：值idx，从0开始
int valueIdx = Integer.parseInt(args[4]);
- // 参数6：chunkAvgTimeLen
- long chunkAvgTimeLen = Long.parseLong(args[5]);
if (deletePercentage < 0 || deletePercentage > 100) {
throw new IOException("WRONG deletePercentage!");
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/WriteSyntheticData1.java b/example/session/src/main/java/org/apache/iotdb/writeData/WriteSyntheticData1.java
deleted file mode 100644
index fbc9664..0000000
--- a/example/session/src/main/java/org/apache/iotdb/writeData/WriteSyntheticData1.java
+++ /dev/null
@@ -1,46 +0,0 @@
-// package org.apache.iotdb.writeData;
-//
-// import org.apache.iotdb.rpc.IoTDBConnectionException;
-// import org.apache.iotdb.rpc.StatementExecutionException;
-// import org.apache.iotdb.session.Session;
-// import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-//
-// import java.util.Collections;
-//
-// public class WriteSyntheticData1 {
-//
-// /**
-// * !!!!!!!Before writing data, make sure check the following server parameters:
-// *
-// * <p>system_dir=/data3/ruilei/iotdb-server-0.12.4/synData1/system
-// * data_dirs=/data3/ruilei/iotdb-server-0.12.4/synData1/data
-// * wal_dir=/data3/ruilei/iotdb-server-0.12.4/synData1/wal timestamp_precision=ms
-// * unseq_tsfile_size=1073741824 # maximum size of unseq TsFile is 1024^3 Bytes
-// * seq_tsfile_size=1073741824 # maximum size of seq TsFile is 1024^3 Bytes
-// * avg_series_point_number_threshold=10000 # each chunk contains 10000 data points
-// * compaction_strategy=NO_COMPACTION # compaction between levels is disabled
-// * enable_unseq_compaction=false # unseq compaction is disabled
-// */
-// public static final String device = "root.vehicle.d0";
-//
-// public static final String measurements = "s0";
-//
-// public static void main(String[] args)
-// throws IoTDBConnectionException, StatementExecutionException {
-//
-// Session session = new Session("127.0.0.1", 6667, "root", "root");
-// session.open(false);
-//
-// for (long timestamp = 0; timestamp < 10000000; timestamp++) {
-// double value = Math.random();
-// session.insertRecord(
-// device,
-// timestamp,
-// Collections.singletonList(measurements),
-// Collections.singletonList(TSDataType.DOUBLE),
-// value);
-// }
-// session.executeNonQueryStatement("flush");
-// session.close();
-// }
-// }
diff --git a/example/session/src/main/java/org/apache/iotdb/writeData/WriteSyntheticDataWithDeletes.java b/example/session/src/main/java/org/apache/iotdb/writeData/WriteSyntheticDataWithDeletes.java
deleted file mode 100644
index 3a6f918..0000000
--- a/example/session/src/main/java/org/apache/iotdb/writeData/WriteSyntheticDataWithDeletes.java
+++ /dev/null
@@ -1,64 +0,0 @@
-// package org.apache.iotdb.writeData;
-//
-// import org.apache.iotdb.rpc.IoTDBConnectionException;
-// import org.apache.iotdb.rpc.StatementExecutionException;
-// import org.apache.iotdb.session.Session;
-// import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
-//
-// import java.util.ArrayList;
-// import java.util.Collections;
-// import java.util.List;
-// import java.util.Random;
-//
-// public class WriteSyntheticDataWithDeletes {
-//
-// /**
-// * !!!!!!!Before writing data, make sure check the following server parameters:
-// *
-// * <p>system_dir data_dirs wal_dir timestamp_precision=ms unseq_tsfile_size=1073741824 # maximum
-// * size of unseq TsFile is 1024^3 Bytes seq_tsfile_size=1073741824 # maximum size of seq TsFile
-// is
-// * 1024^3 Bytes avg_series_point_number_threshold=10000 # each chunk contains 10000 data points
-// * compaction_strategy=NO_COMPACTION # compaction between levels is disabled
-// * enable_unseq_compaction=false # unseq compaction is disabled
-// */
-// public static final String device = "root.vehicle.d0";
-//
-// public static final String measurements = "s0";
-//
-// public static void main(String[] args)
-// throws IoTDBConnectionException, StatementExecutionException {
-// // 实验自变量1：每隔deleteFreq时间（本实验时间单位ms）就执行一次删除
-// long deleteFreq = Long.parseLong(args[0]);
-// // 实验自变量2：每次删除的时间长度
-// long deleteLen = Long.parseLong(args[1]);
-//
-// Session session = new Session("127.0.0.1", 6667, "root", "root");
-// session.open(false);
-//
-// List<String> paths = new ArrayList<>();
-// paths.add(device + "." + measurements);
-//
-// for (long timestamp = 0; timestamp < 10000000; timestamp++) {
-// if (timestamp != 0 && timestamp % deleteFreq == 0) {
-// // [timestamp-deleteFreq, timestamp-1]内随机取一个删除时间起点
-// long min = timestamp - deleteFreq;
-// long max = timestamp - 1;
-// long deleteStartTime = min + (((long) (new Random().nextDouble() * (max - min))));
-// // delete length 5000ms, half the time length of a chunk
-// long deleteEndTime = deleteStartTime + deleteLen;
-// session.deleteData(paths, deleteStartTime, deleteEndTime);
-// }
-//
-// double value = Math.random();
-// session.insertRecord(
-// device,
-// timestamp,
-// Collections.singletonList(measurements),
-// Collections.singletonList(TSDataType.DOUBLE),
-// value);
-// }
-// session.executeNonQueryStatement("flush");
-// session.close();
-// }
-// }