This is an automated email from the ASF dual-hosted git repository. leirui pushed a commit to branch research/LTS-visualization in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 13363e3955f430a3592a91768e5da3736585575a Author: Lei Rui <[email protected]> AuthorDate: Mon Sep 30 18:31:29 2024 +0800 test --- .../dataset/groupby/GroupByWithoutValueFilterDataSet.java | 5 +++++ .../db/query/dataset/groupby/LocalGroupByExecutorTri_M4.java | 2 ++ .../iotdb/db/query/simpiece/MySample_fsw_motivation.java | 12 ++++-------- 3 files changed, 11 insertions(+), 8 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByWithoutValueFilterDataSet.java b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByWithoutValueFilterDataSet.java index 4e4e97f5307..ce72b2db444 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByWithoutValueFilterDataSet.java +++ b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByWithoutValueFilterDataSet.java @@ -180,6 +180,11 @@ public class GroupByWithoutValueFilterDataSet extends GroupByEngineDataSet { record.addField(series, TSDataType.MIN_MAX_INT64); + // clear + pathExecutors.clear(); + pathExecutors = null; + System.gc(); + } catch (QueryProcessException e) { logger.error("GroupByWithoutValueFilterDataSet execute has error", e); throw new IOException(e.getMessage(), e); diff --git a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutorTri_M4.java b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutorTri_M4.java index fac9cb286df..9a3df0853cc 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutorTri_M4.java +++ b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutorTri_M4.java @@ -368,6 +368,8 @@ public class LocalGroupByExecutorTri_M4 implements GroupByExecutor { MinValueAggrResult minValueAggrResult = (MinValueAggrResult) results.get(0); minValueAggrResult.updateResult(new MinMaxInfo<>(series.toString(), 0)); + timeSeries = null; + return results; } diff --git a/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_fsw_motivation.java b/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_fsw_motivation.java index d0c738e04d6..2fd10b69e80 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_fsw_motivation.java +++ b/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_fsw_motivation.java @@ -32,8 +32,8 @@ public class MySample_fsw_motivation { public static void main(String[] args) { String file = "tmp.csv"; String out = "tmp-fsw.csv"; - int[] noutList = new int[]{7}; - double[] epsilonList = new double[]{3.342602252960205}; + int[] noutList = new int[] {7}; + double[] epsilonList = new double[] {3.342602252960205}; for (int nout : noutList) { boolean hasHeader = false; @@ -42,14 +42,10 @@ public class MySample_fsw_motivation { TimeSeries ts = TimeSeriesReader.getMyTimeSeries( inputStream, delimiter, false, -1, 0, hasHeader, false); -// double epsilon = getFSWParam(nout, ts, 1e-6); + // double epsilon = getFSWParam(nout, ts, 1e-6); double epsilon = epsilonList[0]; List<Point> reducedPoints = FSW.reducePoints(ts.data, epsilon); - System.out.println( - "epsilon=" - + epsilon - + ",actual m=" - + reducedPoints.size()); + System.out.println("epsilon=" + epsilon + ",actual m=" + reducedPoints.size()); try (PrintWriter writer = new PrintWriter(new FileWriter(out))) { for (Point p : reducedPoints) { writer.println(p.getTimestamp() + "," + p.getValue());
