demus/openhab-addons
1
0
Fork 0
mirror of https://github.com/openhab/openhab-addons.git synced 2025-01-10 15:11:59 +01:00
Code Issues Packages Projects Releases Wiki Activity

[rrd4j] Reuse the state for identical values (#16379)

Browse Source 
Signed-off-by: Jörg Sautter <joerg.sautter@gmx.net>
Signed-off-by: Ciprian Pascu <contact@ciprianpascu.ro>
This commit is contained in:
joerg1985 2024-02-08 07:49:03 +01:00 committed by Ciprian Pascu
parent 56a4ca07e7
commit 3507b77ca9
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
bundles/org.openhab.persistence.rrd4j/src/main/java/org/openhab/persistence/rrd4j/internal/RRD4jPersistenceService.java
View File

@ -491,9 +491,21 @@ public class RRD4jPersistenceService implements QueryablePersistenceService {
long ts = result.getFirstTimestamp();
ZonedDateTime zdt = ZonedDateTime.ofInstant(Instant.ofEpochSecond(ts), ZoneId.systemDefault());
long step = result.getRowCount() > 1 ? result.getStep() : 0;
double prevValue = Double.NaN;
State prevState = null;
for (double value : result.getValues(DATASOURCE_STATE)) {
if (!Double.isNaN(value) && (((ts >= start) && (ts <= end)) || (start == end))) {
RRD4jItem rrd4jItem = new RRD4jItem(itemName, toState.apply(value), zdt);
State state;
if (prevValue == value) {
state = prevState;
} else {
prevState = state = toState.apply(value);
prevValue = value;
}
RRD4jItem rrd4jItem = new RRD4jItem(itemName, state, zdt);
items.add(rrd4jItem);
}
zdt = zdt.plusSeconds(step);