This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/tsfile.git
The following commit(s) were added to refs/heads/develop by this push:
new ca6ada41 fix GroupByMonthFilter.getTimeRanges (#609)
ca6ada41 is described below
commit ca6ada41caef38d745fb99dd1f062f397077eb00
Author: shuwenwei <[email protected]>
AuthorDate: Sat Oct 25 09:48:35 2025 +0800
fix GroupByMonthFilter.getTimeRanges (#609)
---
.../tsfile/read/filter/operator/GroupByMonthFilter.java | 11 +++++++++++
1 file changed, 11 insertions(+)
diff --git
a/java/tsfile/src/main/java/org/apache/tsfile/read/filter/operator/GroupByMonthFilter.java
b/java/tsfile/src/main/java/org/apache/tsfile/read/filter/operator/GroupByMonthFilter.java
index 3cef1724..d0c29105 100644
---
a/java/tsfile/src/main/java/org/apache/tsfile/read/filter/operator/GroupByMonthFilter.java
+++
b/java/tsfile/src/main/java/org/apache/tsfile/read/filter/operator/GroupByMonthFilter.java
@@ -19,6 +19,7 @@
package org.apache.tsfile.read.filter.operator;
+import org.apache.tsfile.read.common.TimeRange;
import org.apache.tsfile.read.filter.basic.Filter;
import org.apache.tsfile.read.filter.basic.OperatorType;
import org.apache.tsfile.utils.ReadWriteIOUtils;
@@ -29,6 +30,8 @@ import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.Arrays;
import java.util.Calendar;
+import java.util.Collections;
+import java.util.List;
import java.util.Objects;
import java.util.TimeZone;
import java.util.concurrent.TimeUnit;
@@ -139,6 +142,14 @@ public class GroupByMonthFilter extends GroupByFilter {
}
}
+ @Override
+ public List<TimeRange> getTimeRanges() {
+ // this.startTime will be modified dynamically
+ return originalStartTime >= originalEndTime
+ ? Collections.emptyList()
+ : Collections.singletonList(new TimeRange(originalStartTime,
originalEndTime - 1));
+ }
+
private boolean isContainedByCurrentInterval(long startTime, long endTime) {
if (startTime < this.startTime || endTime > this.endTime) {
return false;