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 49be4fc09223b45d36b46a34f781f954646b8f59 Author: Lei Rui <[email protected]> AuthorDate: Wed Oct 2 00:38:41 2024 +0800 add --- .../src/main/java/org/apache/iotdb/db/query/simpiece/MySample_fsw.java | 2 +- .../java/org/apache/iotdb/db/query/simpiece/MySample_shrinkingcone.java | 2 +- .../main/java/org/apache/iotdb/db/query/simpiece/MySample_simpiece.java | 2 +- .../main/java/org/apache/iotdb/db/query/simpiece/TimeSeriesReader.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_fsw.java b/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_fsw.java index 358b1e2d891..3dfd5cecb9b 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_fsw.java +++ b/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_fsw.java @@ -49,7 +49,7 @@ public class MySample_fsw { String delimiter = ","; TimeSeries ts = TimeSeriesReader.getMyTimeSeries( - inputStream, delimiter, false, N, start, hasHeader, false); + inputStream, delimiter, false, N, start, hasHeader, true); // double epsilon = getFSWParam(nout, ts, 1e-6); double epsilon = epsilonList[y]; List<Point> reducedPoints = FSW.reducePoints(ts.data, epsilon); diff --git a/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_shrinkingcone.java b/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_shrinkingcone.java index f2e88ca98f3..8c269f5d6b6 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_shrinkingcone.java +++ b/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_shrinkingcone.java @@ -49,7 +49,7 @@ public class MySample_shrinkingcone { String delimiter = ","; TimeSeries ts = TimeSeriesReader.getMyTimeSeries( - inputStream, delimiter, false, N, start, hasHeader, false); + inputStream, delimiter, false, N, start, hasHeader, true); // double epsilon = getSCParam(nout, ts, 1e-6); double epsilon = epsilonList[y]; List<Point> reducedPoints = ShrinkingCone.reducePoints(ts.data, epsilon); diff --git a/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_simpiece.java b/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_simpiece.java index c0f64f24a46..35ced19e20c 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_simpiece.java +++ b/server/src/main/java/org/apache/iotdb/db/query/simpiece/MySample_simpiece.java @@ -51,7 +51,7 @@ public class MySample_simpiece { String delimiter = ","; TimeSeries ts = TimeSeriesReader.getMyTimeSeries( - inputStream, delimiter, false, N, start, hasHeader, false); + inputStream, delimiter, false, N, start, hasHeader, true); // double epsilon = getSimPieceParam(nout, ts, 1e-6); double epsilon = epsilonList[y]; SimPiece simPiece = new SimPiece(ts.data, epsilon); diff --git a/server/src/main/java/org/apache/iotdb/db/query/simpiece/TimeSeriesReader.java b/server/src/main/java/org/apache/iotdb/db/query/simpiece/TimeSeriesReader.java index 29eb0003d6d..57476066243 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/simpiece/TimeSeriesReader.java +++ b/server/src/main/java/org/apache/iotdb/db/query/simpiece/TimeSeriesReader.java @@ -197,7 +197,7 @@ public class TimeSeriesReader { if (!seriesTimeColumn) { timestamp = (long) Double.parseDouble(elements[0]); } else { - timestamp = cnt + 1; + timestamp = cnt; // for DFT, DWT, OM3 } double value = Double.parseDouble(elements[1]); ts.add(new Point(timestamp, value));
