diff options
Diffstat (limited to 'impl_core/src/test/java/io/opencensus/implcore/stats/MutableViewDataTest.java')
| -rw-r--r-- | impl_core/src/test/java/io/opencensus/implcore/stats/MutableViewDataTest.java | 114 |
1 files changed, 0 insertions, 114 deletions
diff --git a/impl_core/src/test/java/io/opencensus/implcore/stats/MutableViewDataTest.java b/impl_core/src/test/java/io/opencensus/implcore/stats/MutableViewDataTest.java index e397ad65..06f50fed 100644 --- a/impl_core/src/test/java/io/opencensus/implcore/stats/MutableViewDataTest.java +++ b/impl_core/src/test/java/io/opencensus/implcore/stats/MutableViewDataTest.java @@ -18,35 +18,7 @@ package io.opencensus.implcore.stats; import static com.google.common.truth.Truth.assertThat; -import com.google.common.collect.ImmutableMap; import io.opencensus.common.Timestamp; -import io.opencensus.implcore.stats.MutableAggregation.MutableCount; -import io.opencensus.implcore.stats.MutableAggregation.MutableDistribution; -import io.opencensus.implcore.stats.MutableAggregation.MutableLastValue; -import io.opencensus.implcore.stats.MutableAggregation.MutableMean; -import io.opencensus.implcore.stats.MutableAggregation.MutableSum; -import io.opencensus.stats.Aggregation.Count; -import io.opencensus.stats.Aggregation.Distribution; -import io.opencensus.stats.Aggregation.LastValue; -import io.opencensus.stats.Aggregation.Mean; -import io.opencensus.stats.Aggregation.Sum; -import io.opencensus.stats.AggregationData; -import io.opencensus.stats.AggregationData.CountData; -import io.opencensus.stats.AggregationData.DistributionData; -import io.opencensus.stats.AggregationData.LastValueDataDouble; -import io.opencensus.stats.AggregationData.LastValueDataLong; -import io.opencensus.stats.AggregationData.MeanData; -import io.opencensus.stats.AggregationData.SumDataDouble; -import io.opencensus.stats.AggregationData.SumDataLong; -import io.opencensus.stats.BucketBoundaries; -import io.opencensus.stats.Measure.MeasureDouble; -import io.opencensus.stats.Measure.MeasureLong; -import io.opencensus.tags.TagKey; -import io.opencensus.tags.TagValue; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.List; -import java.util.Map; import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.JUnit4; @@ -55,94 +27,8 @@ import org.junit.runners.JUnit4; @RunWith(JUnit4.class) public class MutableViewDataTest { - private static final double EPSILON = 1e-7; - - private static final TagKey ORIGINATOR = TagKey.create("originator"); - private static final TagKey CALLER = TagKey.create("caller"); - private static final TagKey METHOD = TagKey.create("method"); - private static final TagValue CALLER_V = TagValue.create("some caller"); - private static final TagValue METHOD_V = TagValue.create("some method"); - private static final MeasureDouble MEASURE_DOUBLE = - MeasureDouble.create("measure1", "description", "1"); - private static final MeasureLong MEASURE_LONG = - MeasureLong.create("measure2", "description", "1"); - @Test public void testConstants() { - assertThat(MutableViewData.UNKNOWN_TAG_VALUE).isNull(); assertThat(MutableViewData.ZERO_TIMESTAMP).isEqualTo(Timestamp.create(0, 0)); } - - @Test - public void testGetTagValues() { - List<TagKey> columns = Arrays.asList(CALLER, METHOD, ORIGINATOR); - Map<TagKey, TagValue> tags = ImmutableMap.of(CALLER, CALLER_V, METHOD, METHOD_V); - - assertThat(MutableViewData.getTagValues(tags, columns)) - .containsExactly(CALLER_V, METHOD_V, MutableViewData.UNKNOWN_TAG_VALUE) - .inOrder(); - } - - @Test - public void createMutableAggregation() { - BucketBoundaries bucketBoundaries = BucketBoundaries.create(Arrays.asList(-1.0, 0.0, 1.0)); - - assertThat(((MutableSum) MutableViewData.createMutableAggregation(Sum.create())).getSum()) - .isWithin(EPSILON) - .of(0.0); - assertThat(((MutableCount) MutableViewData.createMutableAggregation(Count.create())).getCount()) - .isEqualTo(0L); - assertThat(((MutableMean) MutableViewData.createMutableAggregation(Mean.create())).getMean()) - .isWithin(EPSILON) - .of(0D); - assertThat( - ((MutableLastValue) MutableViewData.createMutableAggregation(LastValue.create())) - .getLastValue()) - .isNaN(); - - MutableDistribution mutableDistribution = - (MutableDistribution) - MutableViewData.createMutableAggregation(Distribution.create(bucketBoundaries)); - assertThat(mutableDistribution.getMin()).isPositiveInfinity(); - assertThat(mutableDistribution.getMax()).isNegativeInfinity(); - assertThat(mutableDistribution.getSumOfSquaredDeviations()).isWithin(EPSILON).of(0); - assertThat(mutableDistribution.getBucketCounts()).isEqualTo(new long[4]); - } - - @Test - public void createAggregationData() { - BucketBoundaries bucketBoundaries = BucketBoundaries.create(Arrays.asList(-1.0, 0.0, 1.0)); - List<AggregationData> aggregates = new ArrayList<AggregationData>(); - aggregates.add(MutableViewData.createAggregationData(MutableSum.create(), MEASURE_DOUBLE)); - aggregates.add(MutableViewData.createAggregationData(MutableSum.create(), MEASURE_LONG)); - aggregates.add( - MutableViewData.createAggregationData(MutableLastValue.create(), MEASURE_DOUBLE)); - aggregates.add(MutableViewData.createAggregationData(MutableLastValue.create(), MEASURE_LONG)); - - List<MutableAggregation> mutableAggregations = - Arrays.asList( - MutableCount.create(), - MutableMean.create(), - MutableDistribution.create(bucketBoundaries)); - for (MutableAggregation mutableAggregation : mutableAggregations) { - aggregates.add(MutableViewData.createAggregationData(mutableAggregation, MEASURE_DOUBLE)); - } - - assertThat(aggregates) - .containsExactly( - SumDataDouble.create(0), - SumDataLong.create(0), - LastValueDataDouble.create(Double.NaN), - LastValueDataLong.create(0), - CountData.create(0), - MeanData.create(0, 0), - DistributionData.create( - 0, - 0, - Double.POSITIVE_INFINITY, - Double.NEGATIVE_INFINITY, - 0, - Arrays.asList(new Long[] {0L, 0L, 0L, 0L}))) - .inOrder(); - } } |