nick
2 years ago
40 changed files with 862 additions and 118 deletions
@ -0,0 +1,66 @@ |
|||||
|
/** |
||||
|
* Copyright © 2016-2025 The Thingsboard Authors |
||||
|
* |
||||
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
|
* you may not use this file except in compliance with the License. |
||||
|
* You may obtain a copy of the License at |
||||
|
* |
||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
|
* |
||||
|
* Unless required by applicable law or agreed to in writing, software |
||||
|
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
|
* See the License for the specific language governing permissions and |
||||
|
* limitations under the License. |
||||
|
*/ |
||||
|
package org.thingsboard.script.api.tbel; |
||||
|
|
||||
|
import com.fasterxml.jackson.annotation.JsonIgnore; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
@Data |
||||
|
public class TbelCfTsMultiDoubleVal implements TbelCfObject { |
||||
|
|
||||
|
public static final long OBJ_SIZE = 32L; // Approximate calculation;
|
||||
|
|
||||
|
private final long ts; |
||||
|
private final double[] values; |
||||
|
|
||||
|
@JsonIgnore |
||||
|
public double getV1() { |
||||
|
return getV(0); |
||||
|
} |
||||
|
|
||||
|
@JsonIgnore |
||||
|
public double getV2() { |
||||
|
return getV(1); |
||||
|
} |
||||
|
|
||||
|
@JsonIgnore |
||||
|
public double getV3() { |
||||
|
return getV(2); |
||||
|
} |
||||
|
|
||||
|
@JsonIgnore |
||||
|
public double getV4() { |
||||
|
return getV(3); |
||||
|
} |
||||
|
|
||||
|
@JsonIgnore |
||||
|
public double getV5() { |
||||
|
return getV(4); |
||||
|
} |
||||
|
|
||||
|
private double getV(int idx) { |
||||
|
if (values.length < idx + 1) { |
||||
|
throw new IllegalArgumentException("Can't get value at index " + idx + ". There are " + values.length + " values present."); |
||||
|
} else { |
||||
|
return values[idx]; |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public long memorySize() { |
||||
|
return OBJ_SIZE + values.length * 8L; |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,61 @@ |
|||||
|
/** |
||||
|
* Copyright © 2016-2025 The Thingsboard Authors |
||||
|
* |
||||
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
|
* you may not use this file except in compliance with the License. |
||||
|
* You may obtain a copy of the License at |
||||
|
* |
||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
|
* |
||||
|
* Unless required by applicable law or agreed to in writing, software |
||||
|
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
|
* See the License for the specific language governing permissions and |
||||
|
* limitations under the License. |
||||
|
*/ |
||||
|
package org.thingsboard.script.api.tbel; |
||||
|
|
||||
|
import com.fasterxml.jackson.annotation.JsonIgnore; |
||||
|
import lombok.Getter; |
||||
|
|
||||
|
import java.util.ArrayList; |
||||
|
import java.util.Collections; |
||||
|
import java.util.Iterator; |
||||
|
import java.util.List; |
||||
|
import java.util.function.Consumer; |
||||
|
|
||||
|
import static org.thingsboard.script.api.tbel.TbelCfTsDoubleVal.OBJ_SIZE; |
||||
|
|
||||
|
public class TbelCfTsRollingData implements TbelCfObject, Iterable<TbelCfTsMultiDoubleVal> { |
||||
|
|
||||
|
@Getter |
||||
|
private final TbTimeWindow timeWindow; |
||||
|
@Getter |
||||
|
private final List<TbelCfTsMultiDoubleVal> values; |
||||
|
|
||||
|
public TbelCfTsRollingData(TbTimeWindow timeWindow, List<TbelCfTsMultiDoubleVal> values) { |
||||
|
this.timeWindow = timeWindow; |
||||
|
this.values = Collections.unmodifiableList(values); |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public long memorySize() { |
||||
|
return 12 + values.size() * OBJ_SIZE; |
||||
|
} |
||||
|
|
||||
|
@JsonIgnore |
||||
|
public List<TbelCfTsMultiDoubleVal> getValue() { |
||||
|
return values; |
||||
|
} |
||||
|
|
||||
|
@JsonIgnore |
||||
|
public int getSize() { |
||||
|
return values.size(); |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public Iterator<TbelCfTsMultiDoubleVal> iterator() { |
||||
|
return values.iterator(); |
||||
|
} |
||||
|
|
||||
|
} |
||||
Loading…
Reference in new issue