aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me/lucko/spark/common/util
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2019-08-03 22:04:20 +0100
committerLuck <git@lucko.me>2019-08-03 22:04:20 +0100
commit2a03b547c7714a130b2bc1407b12a8abd58a9069 (patch)
treec4306958d814964a58c472b959b94afda5ee3800 /spark-common/src/main/java/me/lucko/spark/common/util
parent4308eda6fd4ce3d637ad29b50f53d870ec1facbc (diff)
downloadspark-2a03b547c7714a130b2bc1407b12a8abd58a9069.tar.gz
spark-2a03b547c7714a130b2bc1407b12a8abd58a9069.tar.bz2
spark-2a03b547c7714a130b2bc1407b12a8abd58a9069.zip
Some more reorganising
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) {