dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TbGetTelemetryNode Aggregation feature - count aggIntervalStep when buildQueries for aggregation

Browse Source
This commit is contained in:
Sergey Matvienko 2021-09-28 16:38:53 +03:00
parent 7a2a4b9d01
commit 19d24dbdbc
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/metadata/TbGetTelemetryNode.java
View File

@ -130,8 +130,14 @@ public class TbGetTelemetryNode implements TbNode {
} }
private List<ReadTsKvQuery> buildQueries(TbMsg msg, List<String> keys) { private List<ReadTsKvQuery> buildQueries(TbMsg msg, List<String> keys) {
final Interval interval = getInterval(msg);
final long aggIntervalStep = Aggregation.NONE.equals(aggregation) ? 1 :
// exact how it validates on BaseTimeseriesService.validate()
// see CassandraBaseTimeseriesDao.findAllAsync()
interval.getEndTs() - interval.getStartTs();
return keys.stream() return keys.stream()
.map(key -> new BaseReadTsKvQuery(key, getInterval(msg).getStartTs(), getInterval(msg).getEndTs(), 1, limit, aggregation, getOrderBy())) .map(key -> new BaseReadTsKvQuery(key, interval.getStartTs(), interval.getEndTs(), aggIntervalStep, limit, aggregation, getOrderBy()))
.collect(Collectors.toList()); .collect(Collectors.toList());
} }