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 aeaafe1b7e43ad687f985a104d3bd027987e7817 Author: Lei Rui <[email protected]> AuthorDate: Tue Jun 13 13:45:41 2023 +0800 add M4_QUERY_PARAM for log debug for visualization --- .../iotdb/db/query/dataset/groupby/LocalGroupByExecutor4CPV.java | 8 ++++++++ .../java/org/apache/iotdb/tsfile/read/filter/GroupByFilter.java | 4 ++++ 2 files changed, 12 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutor4CPV.java b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutor4CPV.java index 3cb9b812452..b4c59643688 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutor4CPV.java +++ b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutor4CPV.java @@ -39,6 +39,7 @@ import org.apache.iotdb.tsfile.file.metadata.statistics.LongStatistics; import org.apache.iotdb.tsfile.file.metadata.statistics.Statistics; import org.apache.iotdb.tsfile.read.common.ChunkSuit4CPV; import org.apache.iotdb.tsfile.read.common.TimeRange; +import org.apache.iotdb.tsfile.read.filter.GroupByFilter; import org.apache.iotdb.tsfile.read.filter.basic.Filter; import org.apache.iotdb.tsfile.read.reader.page.PageReader; import org.apache.iotdb.tsfile.utils.Pair; @@ -129,6 +130,13 @@ public class LocalGroupByExecutor4CPV implements GroupByExecutor { }); if (M4_CHUNK_METADATA.isDebugEnabled()) { + if (timeFilter instanceof GroupByFilter) { + M4_CHUNK_METADATA.debug( + "M4_QUERY_PARAM,{},{},{}", + ((GroupByFilter) timeFilter).getStartTime(), + ((GroupByFilter) timeFilter).getEndTime(), + ((GroupByFilter) timeFilter).getInterval()); + } for (ChunkSuit4CPV chunkSuit4CPV : futureChunkList) { Statistics statistics = chunkSuit4CPV.getChunkMetadata().getStatistics(); long FP_t = statistics.getStartTime(); diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/GroupByFilter.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/GroupByFilter.java index d53b450e91c..d44e3cf104e 100644 --- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/GroupByFilter.java +++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/GroupByFilter.java @@ -145,4 +145,8 @@ public class GroupByFilter implements Filter, Serializable { public long getEndTime() { return endTime; } + + public long getInterval() { + return interval; + } }
