Revert "Merge pull request #1774 from kylezh/time_range"
This reverts commitpull/1781/head98f062743b
, reversing changes made to0597cc34f5
.
parent
98f062743b
commit
db91f0caeb
2
tx.go
2
tx.go
|
@ -114,7 +114,7 @@ func (tx *tx) CreateIterators(stmt *influxql.SelectStatement) ([]influxql.Iterat
|
||||||
// Find shard groups within time range.
|
// Find shard groups within time range.
|
||||||
var shardGroups []*ShardGroup
|
var shardGroups []*ShardGroup
|
||||||
for _, group := range rp.shardGroups {
|
for _, group := range rp.shardGroups {
|
||||||
if timeBetweenInclusive(group.StartTime, tmin, tmax) || timeBetweenInclusive(group.EndTime, tmin, tmax) || (group.StartTime.Before(tmin) && group.EndTime.After(tmax)) {
|
if timeBetweenInclusive(group.StartTime, tmin, tmax) || timeBetweenInclusive(group.EndTime, tmin, tmax) {
|
||||||
shardGroups = append(shardGroups, group)
|
shardGroups = append(shardGroups, group)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue