Browse Source

Save time series strategies: naming improvement

pull/12413/head
Dmytro Skarzhynets 1 year ago
parent
commit
708c25d1ec
No known key found for this signature in database GPG Key ID: 2B51652F224037DF
  1. 2
      rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/telemetry/TbMsgTimeseriesNode.java
  2. 4
      rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/telemetry/TbMsgTimeseriesNodeConfiguration.java

2
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/telemetry/TbMsgTimeseriesNode.java

@ -182,7 +182,7 @@ public class TbMsgTimeseriesNode implements TbNode {
return TimeseriesSaveRequest.Strategy.WS_ONLY;
}
if (persistenceSettings instanceof Deduplicate deduplicate) {
boolean isFirstMsgInInterval = deduplicate.getDeduplicateStrategy().shouldPersist(ts, originatorUuid);
boolean isFirstMsgInInterval = deduplicate.getPersistenceStrategy().shouldPersist(ts, originatorUuid);
return isFirstMsgInInterval ? TimeseriesSaveRequest.Strategy.SAVE_ALL : TimeseriesSaveRequest.Strategy.SKIP_ALL;
}
if (persistenceSettings instanceof Advanced advanced) {

4
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/telemetry/TbMsgTimeseriesNodeConfiguration.java

@ -73,12 +73,12 @@ public class TbMsgTimeseriesNodeConfiguration implements NodeConfiguration<TbMsg
private final int deduplicationIntervalSecs;
@JsonIgnore
private final PersistenceStrategy deduplicateStrategy;
private final PersistenceStrategy persistenceStrategy;
@JsonCreator
Deduplicate(@JsonProperty("deduplicationIntervalSecs") int deduplicationIntervalSecs) {
this.deduplicationIntervalSecs = deduplicationIntervalSecs;
deduplicateStrategy = PersistenceStrategy.deduplicate(deduplicationIntervalSecs);
persistenceStrategy = PersistenceStrategy.deduplicate(deduplicationIntervalSecs);
}
}

Loading…
Cancel
Save