Class RiskAggregationBasic<T extends DoubleValue>
- java.lang.Object
-
- io.heraldprox.herald.sensor.analysis.algorithms.risk.RiskAggregationBasic<T>
-
- All Implemented Interfaces:
Aggregate<T>
public class RiskAggregationBasic<T extends DoubleValue> extends java.lang.Object implements Aggregate<T>
-
-
Constructor Summary
Constructors Constructor Description RiskAggregationBasic(double timeScale, double distanceScale, double minimumDistanceClamp, double minimumRiskScoreAtClamp)
RiskAggregationBasic(double timeScale, double distanceScale, double minimumDistanceClamp, double minimumRiskScoreAtClamp, double logScale)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
beginRun(int thisRun)
void
map(Sample<T> value)
java.lang.Double
reduce()
void
reset()
int
runs()
-
-
-
Constructor Detail
-
RiskAggregationBasic
public RiskAggregationBasic(double timeScale, double distanceScale, double minimumDistanceClamp, double minimumRiskScoreAtClamp)
-
RiskAggregationBasic
public RiskAggregationBasic(double timeScale, double distanceScale, double minimumDistanceClamp, double minimumRiskScoreAtClamp, double logScale)
-
-
Method Detail
-
runs
public int runs()
- Specified by:
runs
in interfaceAggregate<T extends DoubleValue>
-
beginRun
public void beginRun(int thisRun)
- Specified by:
beginRun
in interfaceAggregate<T extends DoubleValue>
-
map
public void map(@NonNull Sample<T> value)
- Specified by:
map
in interfaceAggregate<T extends DoubleValue>
-
reduce
public java.lang.Double reduce()
- Specified by:
reduce
in interfaceAggregate<T extends DoubleValue>
-
reset
public void reset()
- Specified by:
reset
in interfaceAggregate<T extends DoubleValue>
-
-