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

Compilation fix

Browse Source
This commit is contained in:
Volodymyr Babak 2018-09-11 09:44:14 +03:00
parent a12a1ebea2
commit c8b5b2f132
1 changed files with 5 additions and 3 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

@ -25,7 +25,9 @@ import lombok.extern.slf4j.Slf4j;
import org.thingsboard.rule.engine.api.*; import org.thingsboard.rule.engine.api.*;
import org.thingsboard.rule.engine.api.util.DonAsynchron; import org.thingsboard.rule.engine.api.util.DonAsynchron;
import org.thingsboard.rule.engine.api.util.TbNodeUtils; import org.thingsboard.rule.engine.api.util.TbNodeUtils;
import org.thingsboard.server.common.data.kv.BaseReadTsKvQuery;
import org.thingsboard.server.common.data.kv.BaseTsKvQuery; import org.thingsboard.server.common.data.kv.BaseTsKvQuery;
import org.thingsboard.server.common.data.kv.ReadTsKvQuery;
import org.thingsboard.server.common.data.kv.TsKvEntry; import org.thingsboard.server.common.data.kv.TsKvEntry;
import org.thingsboard.server.common.data.kv.TsKvQuery; import org.thingsboard.server.common.data.kv.TsKvQuery;
import org.thingsboard.server.common.data.plugin.ComponentType; import org.thingsboard.server.common.data.plugin.ComponentType;
@ -81,7 +83,7 @@ public class TbGetTelemetryNode implements TbNode {
ctx.tellFailure(msg, new IllegalStateException("Telemetry is not selected!")); ctx.tellFailure(msg, new IllegalStateException("Telemetry is not selected!"));
} else { } else {
try { try {
List<TsKvQuery> queries = buildQueries(); List<ReadTsKvQuery> queries = buildQueries();
ListenableFuture<List<TsKvEntry>> list = ctx.getTimeseriesService().findAll(msg.getOriginator(), queries); ListenableFuture<List<TsKvEntry>> list = ctx.getTimeseriesService().findAll(msg.getOriginator(), queries);
DonAsynchron.withCallback(list, data -> { DonAsynchron.withCallback(list, data -> {
process(data, msg); process(data, msg);
@ -95,13 +97,13 @@ public class TbGetTelemetryNode implements TbNode {
} }
//TODO: handle direction; //TODO: handle direction;
private List<TsKvQuery> buildQueries() { private List<ReadTsKvQuery> buildQueries() {
long ts = System.currentTimeMillis(); long ts = System.currentTimeMillis();
long startTs = ts - startTsOffset; long startTs = ts - startTsOffset;
long endTs = ts - endTsOffset; long endTs = ts - endTsOffset;
return tsKeyNames.stream() return tsKeyNames.stream()
.map(key -> new BaseTsKvQuery(key, startTs, endTs, 1, limit, NONE)) .map(key -> new BaseReadTsKvQuery(key, startTs, endTs, 1, limit, NONE))
.collect(Collectors.toList()); .collect(Collectors.toList());
} }