Skip to content

Commit 5a952e6

Browse files
authored
fix GroupByMonthFilter.getTimeRanges (#610)
1 parent 30d4456 commit 5a952e6

1 file changed

Lines changed: 11 additions & 0 deletions

File tree

java/tsfile/src/main/java/org/apache/tsfile/read/filter/operator/GroupByMonthFilter.java

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919

2020
package org.apache.tsfile.read.filter.operator;
2121

22+
import org.apache.tsfile.read.common.TimeRange;
2223
import org.apache.tsfile.read.filter.basic.Filter;
2324
import org.apache.tsfile.read.filter.basic.OperatorType;
2425
import org.apache.tsfile.utils.ReadWriteIOUtils;
@@ -29,6 +30,8 @@
2930
import java.nio.ByteBuffer;
3031
import java.util.Arrays;
3132
import java.util.Calendar;
33+
import java.util.Collections;
34+
import java.util.List;
3235
import java.util.Objects;
3336
import java.util.TimeZone;
3437
import java.util.concurrent.TimeUnit;
@@ -139,6 +142,14 @@ public boolean containStartEndTime(long startTime, long endTime) {
139142
}
140143
}
141144

145+
@Override
146+
public List<TimeRange> getTimeRanges() {
147+
// this.startTime will be modified dynamically
148+
return originalStartTime >= originalEndTime
149+
? Collections.emptyList()
150+
: Collections.singletonList(new TimeRange(originalStartTime, originalEndTime - 1));
151+
}
152+
142153
private boolean isContainedByCurrentInterval(long startTime, long endTime) {
143154
if (startTime < this.startTime || endTime > this.endTime) {
144155
return false;

0 commit comments

Comments
 (0)