aboutsummaryrefslogtreecommitdiff
path: root/impl_core/src/main/java/io/opencensus/implcore/stats
diff options
context:
space:
mode:
authorKristen Kozak <sebright@google.com>2017-12-20 10:46:38 -0800
committerKristen Kozak <sebright@google.com>2017-12-20 10:50:35 -0800
commita2241dd72616869db521cc18724f7beab85be168 (patch)
tree7f4b2ec26cb012a6a631308e024be23f02ab0465 /impl_core/src/main/java/io/opencensus/implcore/stats
parentd579d8f12b8a76bfb55c538b71d5f014885eb1e0 (diff)
downloadopencensus-java-a2241dd72616869db521cc18724f7beab85be168.tar.gz
Rename NullnessUtils to CheckerFrameworkUtils.
Diffstat (limited to 'impl_core/src/main/java/io/opencensus/implcore/stats')
-rw-r--r--impl_core/src/main/java/io/opencensus/implcore/stats/MutableAggregation.java13
-rw-r--r--impl_core/src/main/java/io/opencensus/implcore/stats/MutableViewData.java15
2 files changed, 17 insertions, 11 deletions
diff --git a/impl_core/src/main/java/io/opencensus/implcore/stats/MutableAggregation.java b/impl_core/src/main/java/io/opencensus/implcore/stats/MutableAggregation.java
index 1a5771eb..49124b00 100644
--- a/impl_core/src/main/java/io/opencensus/implcore/stats/MutableAggregation.java
+++ b/impl_core/src/main/java/io/opencensus/implcore/stats/MutableAggregation.java
@@ -20,7 +20,7 @@ import static com.google.common.base.Preconditions.checkArgument;
import static com.google.common.base.Preconditions.checkNotNull;
import io.opencensus.common.Function;
-import io.opencensus.implcore.internal.NullnessUtils;
+import io.opencensus.implcore.internal.CheckerFrameworkUtils;
import io.opencensus.stats.Aggregation;
import io.opencensus.stats.BucketBoundaries;
@@ -100,7 +100,8 @@ abstract class MutableAggregation {
Function<? super MutableCount, T> p1,
Function<? super MutableMean, T> p2,
Function<? super MutableDistribution, T> p3) {
- return NullnessUtils.<MutableSum, T>removeSuperFromFunctionParameterType(p0).apply(this);
+ return CheckerFrameworkUtils.<MutableSum, T>removeSuperFromFunctionParameterType(p0)
+ .apply(this);
}
}
@@ -146,7 +147,8 @@ abstract class MutableAggregation {
Function<? super MutableCount, T> p1,
Function<? super MutableMean, T> p2,
Function<? super MutableDistribution, T> p3) {
- return NullnessUtils.<MutableCount, T>removeSuperFromFunctionParameterType(p1).apply(this);
+ return CheckerFrameworkUtils.<MutableCount, T>removeSuperFromFunctionParameterType(p1)
+ .apply(this);
}
}
@@ -214,7 +216,8 @@ abstract class MutableAggregation {
Function<? super MutableCount, T> p1,
Function<? super MutableMean, T> p2,
Function<? super MutableDistribution, T> p3) {
- return NullnessUtils.<MutableMean, T>removeSuperFromFunctionParameterType(p2).apply(this);
+ return CheckerFrameworkUtils.<MutableMean, T>removeSuperFromFunctionParameterType(p2)
+ .apply(this);
}
}
@@ -356,7 +359,7 @@ abstract class MutableAggregation {
Function<? super MutableCount, T> p1,
Function<? super MutableMean, T> p2,
Function<? super MutableDistribution, T> p3) {
- return NullnessUtils.<MutableDistribution, T>removeSuperFromFunctionParameterType(p3)
+ return CheckerFrameworkUtils.<MutableDistribution, T>removeSuperFromFunctionParameterType(p3)
.apply(this);
}
}
diff --git a/impl_core/src/main/java/io/opencensus/implcore/stats/MutableViewData.java b/impl_core/src/main/java/io/opencensus/implcore/stats/MutableViewData.java
index 4963ce59..8ecb7dca 100644
--- a/impl_core/src/main/java/io/opencensus/implcore/stats/MutableViewData.java
+++ b/impl_core/src/main/java/io/opencensus/implcore/stats/MutableViewData.java
@@ -26,7 +26,7 @@ import io.opencensus.common.Duration;
import io.opencensus.common.Function;
import io.opencensus.common.Functions;
import io.opencensus.common.Timestamp;
-import io.opencensus.implcore.internal.NullnessUtils;
+import io.opencensus.implcore.internal.CheckerFrameworkUtils;
import io.opencensus.implcore.stats.MutableAggregation.MutableCount;
import io.opencensus.implcore.stats.MutableAggregation.MutableDistribution;
import io.opencensus.implcore.stats.MutableAggregation.MutableMean;
@@ -313,7 +313,7 @@ abstract class MutableViewData {
getTagValues(getTagMap(context), super.view.getColumns());
refreshBucketList(timestamp);
// It is always the last bucket that does the recording.
- NullnessUtils.castNonNull(buckets.peekLast()).record(tagValues, value);
+ CheckerFrameworkUtils.castNonNull(buckets.peekLast()).record(tagValues, value);
}
@Override
@@ -351,7 +351,8 @@ abstract class MutableViewData {
if (buckets.size() != N + 1) {
throw new AssertionError("Bucket list must have exactly " + (N + 1) + " buckets.");
}
- Timestamp startOfLastBucket = NullnessUtils.castNonNull(buckets.peekLast()).getStart();
+ Timestamp startOfLastBucket =
+ CheckerFrameworkUtils.castNonNull(buckets.peekLast()).getStart();
// TODO(songya): decide what to do when time goes backwards
checkArgument(
now.compareTo(startOfLastBucket) >= 0,
@@ -368,7 +369,9 @@ abstract class MutableViewData {
if (!buckets.isEmpty()) {
startOfNewBucket =
- NullnessUtils.castNonNull(buckets.peekLast()).getStart().addDuration(bucketDuration);
+ CheckerFrameworkUtils.castNonNull(buckets.peekLast())
+ .getStart()
+ .addDuration(bucketDuration);
} else {
// Initialize bucket list. Should only enter this block once.
startOfNewBucket = subtractDuration(now, totalDuration);
@@ -418,8 +421,8 @@ abstract class MutableViewData {
Aggregation aggregation,
Timestamp now) {
// Put fractional stats of the head (oldest) bucket.
- IntervalBucket head = NullnessUtils.castNonNull(buckets.peekFirst());
- IntervalBucket tail = NullnessUtils.castNonNull(buckets.peekLast());
+ IntervalBucket head = CheckerFrameworkUtils.castNonNull(buckets.peekFirst());
+ IntervalBucket tail = CheckerFrameworkUtils.castNonNull(buckets.peekLast());
double fractionTail = tail.getFraction(now);
// TODO(songya): decide what to do when time goes backwards
checkArgument(