aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me/lucko/spark/common/util
diff options
context:
space:
mode:
Diffstat (limited to 'spark-common/src/main/java/me/lucko/spark/common/util')
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/util/RollingAverage.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/util/RollingAverage.java b/spark-common/src/main/java/me/lucko/spark/common/util/RollingAverage.java
index 5b1fd21..514876d 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/util/RollingAverage.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/util/RollingAverage.java
@@ -27,12 +27,13 @@ import java.util.Queue;
public class RollingAverage {
- private final Queue<BigDecimal> samples = new ArrayDeque<>();
+ private final Queue<BigDecimal> samples;
private final int size;
private BigDecimal total = BigDecimal.ZERO;
public RollingAverage(int size) {
this.size = size;
+ this.samples = new ArrayDeque<>(this.size);
}
public void add(BigDecimal num) {