diff --git a/extensions-contrib/distinctcount/src/main/java/io/druid/query/aggregation/distinctcount/DistinctCountAggregator.java b/extensions-contrib/distinctcount/src/main/java/io/druid/query/aggregation/distinctcount/DistinctCountAggregator.java index 22f3bfab7ef2..7a0f1d7c8ef5 100644 --- a/extensions-contrib/distinctcount/src/main/java/io/druid/query/aggregation/distinctcount/DistinctCountAggregator.java +++ b/extensions-contrib/distinctcount/src/main/java/io/druid/query/aggregation/distinctcount/DistinctCountAggregator.java @@ -64,12 +64,6 @@ public float getFloat() return (float) mutableBitmap.size(); } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/extensions-contrib/distinctcount/src/main/java/io/druid/query/aggregation/distinctcount/EmptyDistinctCountAggregator.java b/extensions-contrib/distinctcount/src/main/java/io/druid/query/aggregation/distinctcount/EmptyDistinctCountAggregator.java index 5d839c13b2e0..a7338d7ff662 100644 --- a/extensions-contrib/distinctcount/src/main/java/io/druid/query/aggregation/distinctcount/EmptyDistinctCountAggregator.java +++ b/extensions-contrib/distinctcount/src/main/java/io/druid/query/aggregation/distinctcount/EmptyDistinctCountAggregator.java @@ -50,12 +50,6 @@ public float getFloat() return (float) 0; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/extensions-contrib/time-min-max/src/main/java/io/druid/query/aggregation/TimestampAggregator.java b/extensions-contrib/time-min-max/src/main/java/io/druid/query/aggregation/TimestampAggregator.java index 4d9d59bae838..1dcdc3c99c67 100644 --- a/extensions-contrib/time-min-max/src/main/java/io/druid/query/aggregation/TimestampAggregator.java +++ b/extensions-contrib/time-min-max/src/main/java/io/druid/query/aggregation/TimestampAggregator.java @@ -85,12 +85,6 @@ public float getFloat() return (float) most; } - @Override - public String getName() - { - return name; - } - @Override public void close() { diff --git a/extensions-contrib/time-min-max/src/main/java/io/druid/query/aggregation/TimestampAggregatorFactory.java b/extensions-contrib/time-min-max/src/main/java/io/druid/query/aggregation/TimestampAggregatorFactory.java index ae62b7678301..c97e313be997 100644 --- a/extensions-contrib/time-min-max/src/main/java/io/druid/query/aggregation/TimestampAggregatorFactory.java +++ b/extensions-contrib/time-min-max/src/main/java/io/druid/query/aggregation/TimestampAggregatorFactory.java @@ -166,12 +166,6 @@ public int getMaxIntermediateSize() return Longs.BYTES; } - @Override - public Object getAggregatorStartValue() - { - return initValue; - } - @Override public boolean equals(Object o) { diff --git a/extensions-contrib/time-min-max/src/test/java/io/druid/query/aggregation/TimestampMinMaxAggregatorTest.java b/extensions-contrib/time-min-max/src/test/java/io/druid/query/aggregation/TimestampMinMaxAggregatorTest.java index 00823aaafc07..b74f56ce40c3 100644 --- a/extensions-contrib/time-min-max/src/test/java/io/druid/query/aggregation/TimestampMinMaxAggregatorTest.java +++ b/extensions-contrib/time-min-max/src/test/java/io/druid/query/aggregation/TimestampMinMaxAggregatorTest.java @@ -133,8 +133,6 @@ public void testAggregator() { TimestampAggregator aggregator = (TimestampAggregator) aggregatorFactory.factorize(selectorFactory); - Assert.assertEquals(aggType, aggregator.getName()); - for (Timestamp value: values) { aggregate(selector, aggregator); } diff --git a/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/EmptySketchAggregator.java b/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/EmptySketchAggregator.java index b986cbb4c67f..c08010135b67 100644 --- a/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/EmptySketchAggregator.java +++ b/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/EmptySketchAggregator.java @@ -55,12 +55,6 @@ public long getLong() throw new UnsupportedOperationException("Not implemented"); } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SketchAggregator.java b/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SketchAggregator.java index 9132ea88d55a..e2a5ef78bf8a 100644 --- a/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SketchAggregator.java +++ b/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SketchAggregator.java @@ -80,12 +80,6 @@ public long getLong() throw new UnsupportedOperationException("Not implemented"); } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramAggregator.java b/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramAggregator.java index f776d58547ce..8f462fe1c304 100644 --- a/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramAggregator.java +++ b/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramAggregator.java @@ -92,12 +92,6 @@ public long getLong() throw new UnsupportedOperationException("ApproximateHistogramAggregator does not support getLong()"); } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramFoldingAggregator.java b/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramFoldingAggregator.java index ec7d4f4a1746..2084b30f2911 100644 --- a/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramFoldingAggregator.java +++ b/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramFoldingAggregator.java @@ -90,12 +90,6 @@ public long getLong() throw new UnsupportedOperationException("ApproximateHistogramFoldingAggregator does not support getLong()"); } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/extensions-core/stats/src/main/java/io/druid/query/aggregation/variance/VarianceAggregator.java b/extensions-core/stats/src/main/java/io/druid/query/aggregation/variance/VarianceAggregator.java index 2589a16009b1..11a794606b7d 100644 --- a/extensions-core/stats/src/main/java/io/druid/query/aggregation/variance/VarianceAggregator.java +++ b/extensions-core/stats/src/main/java/io/druid/query/aggregation/variance/VarianceAggregator.java @@ -46,12 +46,6 @@ public Object get() return holder; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/processing/src/main/java/io/druid/query/aggregation/AggregatorFactory.java b/processing/src/main/java/io/druid/query/aggregation/AggregatorFactory.java index 2bdc2b2298e7..083841e3dd0a 100644 --- a/processing/src/main/java/io/druid/query/aggregation/AggregatorFactory.java +++ b/processing/src/main/java/io/druid/query/aggregation/AggregatorFactory.java @@ -126,15 +126,6 @@ public AggregatorFactory getMergingFactory(AggregatorFactory other) throws Aggre */ public abstract int getMaxIntermediateSize(); - /** - * Deprecated, to be removed in 0.10.0. See https://github.com/druid-io/druid/issues/3588. - */ - @Deprecated - public Object getAggregatorStartValue() - { - throw new UnsupportedOperationException("getAggregatorStartValue is deprecated"); - } - /** * Merges the list of AggregatorFactory[] (presumable from metadata of some segments being merged) and * returns merged AggregatorFactory[] (for the metadata for merged segment). diff --git a/processing/src/main/java/io/druid/query/aggregation/Aggregators.java b/processing/src/main/java/io/druid/query/aggregation/Aggregators.java index 41d70fb3092b..068784d8d6e1 100644 --- a/processing/src/main/java/io/druid/query/aggregation/Aggregators.java +++ b/processing/src/main/java/io/druid/query/aggregation/Aggregators.java @@ -53,12 +53,6 @@ public float getFloat() return 0; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/processing/src/main/java/io/druid/query/aggregation/CountAggregator.java b/processing/src/main/java/io/druid/query/aggregation/CountAggregator.java index aa6c0c27cdb0..7af2efc68d0e 100644 --- a/processing/src/main/java/io/druid/query/aggregation/CountAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/CountAggregator.java @@ -68,12 +68,6 @@ public long getLong() return count; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public Aggregator clone() { diff --git a/processing/src/main/java/io/druid/query/aggregation/DoubleMaxAggregator.java b/processing/src/main/java/io/druid/query/aggregation/DoubleMaxAggregator.java index 40cf60dcf71b..3e664833cf14 100644 --- a/processing/src/main/java/io/druid/query/aggregation/DoubleMaxAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/DoubleMaxAggregator.java @@ -75,12 +75,6 @@ public long getLong() return (long) max; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public Aggregator clone() { diff --git a/processing/src/main/java/io/druid/query/aggregation/DoubleMinAggregator.java b/processing/src/main/java/io/druid/query/aggregation/DoubleMinAggregator.java index b058a81731df..bc84dd0e380f 100644 --- a/processing/src/main/java/io/druid/query/aggregation/DoubleMinAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/DoubleMinAggregator.java @@ -75,12 +75,6 @@ public long getLong() return (long) min; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public Aggregator clone() { diff --git a/processing/src/main/java/io/druid/query/aggregation/DoubleSumAggregator.java b/processing/src/main/java/io/druid/query/aggregation/DoubleSumAggregator.java index f5f5ef6b3599..07877249d7f9 100644 --- a/processing/src/main/java/io/druid/query/aggregation/DoubleSumAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/DoubleSumAggregator.java @@ -84,12 +84,6 @@ public long getLong() return (long) sum; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public Aggregator clone() { diff --git a/processing/src/main/java/io/druid/query/aggregation/FilteredAggregator.java b/processing/src/main/java/io/druid/query/aggregation/FilteredAggregator.java index 6fedac5b0cb5..179335f18fad 100644 --- a/processing/src/main/java/io/druid/query/aggregation/FilteredAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/FilteredAggregator.java @@ -64,12 +64,6 @@ public long getLong() return delegate.getLong(); } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/processing/src/main/java/io/druid/query/aggregation/HistogramAggregator.java b/processing/src/main/java/io/druid/query/aggregation/HistogramAggregator.java index d9e813896b39..3f77272bef2a 100644 --- a/processing/src/main/java/io/druid/query/aggregation/HistogramAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/HistogramAggregator.java @@ -80,12 +80,6 @@ public long getLong() throw new UnsupportedOperationException("HistogramAggregator does not support getLong()"); } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/processing/src/main/java/io/druid/query/aggregation/JavaScriptAggregator.java b/processing/src/main/java/io/druid/query/aggregation/JavaScriptAggregator.java index 35597a1ddd00..159dae0856e4 100644 --- a/processing/src/main/java/io/druid/query/aggregation/JavaScriptAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/JavaScriptAggregator.java @@ -80,12 +80,6 @@ public long getLong() return (long) current; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public void close() { diff --git a/processing/src/main/java/io/druid/query/aggregation/LongMaxAggregator.java b/processing/src/main/java/io/druid/query/aggregation/LongMaxAggregator.java index 09c8eac9736a..54743bc4aa38 100644 --- a/processing/src/main/java/io/druid/query/aggregation/LongMaxAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/LongMaxAggregator.java @@ -75,12 +75,6 @@ public long getLong() return max; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public Aggregator clone() { diff --git a/processing/src/main/java/io/druid/query/aggregation/LongMinAggregator.java b/processing/src/main/java/io/druid/query/aggregation/LongMinAggregator.java index 29b7afdb1005..dd52a05ea172 100644 --- a/processing/src/main/java/io/druid/query/aggregation/LongMinAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/LongMinAggregator.java @@ -75,12 +75,6 @@ public long getLong() return min; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public Aggregator clone() { diff --git a/processing/src/main/java/io/druid/query/aggregation/LongSumAggregator.java b/processing/src/main/java/io/druid/query/aggregation/LongSumAggregator.java index 7a5a271e7362..e730f2197c5e 100644 --- a/processing/src/main/java/io/druid/query/aggregation/LongSumAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/LongSumAggregator.java @@ -83,12 +83,6 @@ public long getLong() return sum; } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public Aggregator clone() { diff --git a/processing/src/main/java/io/druid/query/aggregation/cardinality/CardinalityAggregator.java b/processing/src/main/java/io/druid/query/aggregation/cardinality/CardinalityAggregator.java index 6d6d0f346d7b..7972b8eb2dc6 100644 --- a/processing/src/main/java/io/druid/query/aggregation/cardinality/CardinalityAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/cardinality/CardinalityAggregator.java @@ -112,12 +112,6 @@ public long getLong() throw new UnsupportedOperationException("CardinalityAggregator does not support getLong()"); } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public Aggregator clone() { diff --git a/processing/src/main/java/io/druid/query/aggregation/first/DoubleFirstAggregator.java b/processing/src/main/java/io/druid/query/aggregation/first/DoubleFirstAggregator.java index bc709de39138..2a44dbc1e42c 100644 --- a/processing/src/main/java/io/druid/query/aggregation/first/DoubleFirstAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/first/DoubleFirstAggregator.java @@ -76,12 +76,6 @@ public float getFloat() return (float) firstValue; } - @Override - public String getName() - { - return name; - } - @Override public void close() { diff --git a/processing/src/main/java/io/druid/query/aggregation/first/DoubleFirstAggregatorFactory.java b/processing/src/main/java/io/druid/query/aggregation/first/DoubleFirstAggregatorFactory.java index 192f8c363301..f63c398adb37 100644 --- a/processing/src/main/java/io/druid/query/aggregation/first/DoubleFirstAggregatorFactory.java +++ b/processing/src/main/java/io/druid/query/aggregation/first/DoubleFirstAggregatorFactory.java @@ -225,12 +225,6 @@ public int getMaxIntermediateSize() return Longs.BYTES + Doubles.BYTES; } - @Override - public Object getAggregatorStartValue() - { - throw new UnsupportedOperationException(); - } - @Override public boolean equals(Object o) { diff --git a/processing/src/main/java/io/druid/query/aggregation/first/LongFirstAggregator.java b/processing/src/main/java/io/druid/query/aggregation/first/LongFirstAggregator.java index 51a5309c73a8..1155d1a5efec 100644 --- a/processing/src/main/java/io/druid/query/aggregation/first/LongFirstAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/first/LongFirstAggregator.java @@ -75,12 +75,6 @@ public float getFloat() return (float) firstValue; } - @Override - public String getName() - { - return name; - } - @Override public void close() { diff --git a/processing/src/main/java/io/druid/query/aggregation/first/LongFirstAggregatorFactory.java b/processing/src/main/java/io/druid/query/aggregation/first/LongFirstAggregatorFactory.java index 459cf4ac2fba..e1d1f1871075 100644 --- a/processing/src/main/java/io/druid/query/aggregation/first/LongFirstAggregatorFactory.java +++ b/processing/src/main/java/io/druid/query/aggregation/first/LongFirstAggregatorFactory.java @@ -215,12 +215,6 @@ public int getMaxIntermediateSize() return Longs.BYTES * 2; } - @Override - public Object getAggregatorStartValue() - { - throw new UnsupportedOperationException(); - } - @Override public boolean equals(Object o) { diff --git a/processing/src/main/java/io/druid/query/aggregation/hyperloglog/HyperUniquesAggregator.java b/processing/src/main/java/io/druid/query/aggregation/hyperloglog/HyperUniquesAggregator.java index bd20e90b9a56..e272ffff5205 100644 --- a/processing/src/main/java/io/druid/query/aggregation/hyperloglog/HyperUniquesAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/hyperloglog/HyperUniquesAggregator.java @@ -70,12 +70,6 @@ public long getLong() throw new UnsupportedOperationException("HyperUniquesAggregator does not support getLong()"); } - @Override - public String getName() - { - throw new UnsupportedOperationException("getName is deprecated"); - } - @Override public Aggregator clone() { diff --git a/processing/src/main/java/io/druid/query/aggregation/last/DoubleLastAggregator.java b/processing/src/main/java/io/druid/query/aggregation/last/DoubleLastAggregator.java index 3e72387ea401..c3bc7fb1758f 100644 --- a/processing/src/main/java/io/druid/query/aggregation/last/DoubleLastAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/last/DoubleLastAggregator.java @@ -76,12 +76,6 @@ public float getFloat() return (float) lastValue; } - @Override - public String getName() - { - return name; - } - @Override public void close() { diff --git a/processing/src/main/java/io/druid/query/aggregation/last/DoubleLastAggregatorFactory.java b/processing/src/main/java/io/druid/query/aggregation/last/DoubleLastAggregatorFactory.java index 302a1cfa791c..bacdfc66b195 100644 --- a/processing/src/main/java/io/druid/query/aggregation/last/DoubleLastAggregatorFactory.java +++ b/processing/src/main/java/io/druid/query/aggregation/last/DoubleLastAggregatorFactory.java @@ -208,12 +208,6 @@ public int getMaxIntermediateSize() return Longs.BYTES + Doubles.BYTES; } - @Override - public Object getAggregatorStartValue() - { - throw new UnsupportedOperationException(); - } - @Override public boolean equals(Object o) { diff --git a/processing/src/main/java/io/druid/query/aggregation/last/LongLastAggregator.java b/processing/src/main/java/io/druid/query/aggregation/last/LongLastAggregator.java index bc312918eeb5..4d18aa141330 100644 --- a/processing/src/main/java/io/druid/query/aggregation/last/LongLastAggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/last/LongLastAggregator.java @@ -74,12 +74,6 @@ public float getFloat() return (float) lastValue; } - @Override - public String getName() - { - return name; - } - @Override public void close() { diff --git a/processing/src/main/java/io/druid/query/aggregation/last/LongLastAggregatorFactory.java b/processing/src/main/java/io/druid/query/aggregation/last/LongLastAggregatorFactory.java index 481e888bbaa1..e4d46815e60b 100644 --- a/processing/src/main/java/io/druid/query/aggregation/last/LongLastAggregatorFactory.java +++ b/processing/src/main/java/io/druid/query/aggregation/last/LongLastAggregatorFactory.java @@ -208,12 +208,6 @@ public int getMaxIntermediateSize() return Longs.BYTES * 2; } - @Override - public Object getAggregatorStartValue() - { - throw new UnsupportedOperationException(); - } - @Override public boolean equals(Object o) { diff --git a/processing/src/test/java/io/druid/query/aggregation/first/DoubleFirstAggregationTest.java b/processing/src/test/java/io/druid/query/aggregation/first/DoubleFirstAggregationTest.java index 1e31600cbd14..24c6b0847293 100644 --- a/processing/src/test/java/io/druid/query/aggregation/first/DoubleFirstAggregationTest.java +++ b/processing/src/test/java/io/druid/query/aggregation/first/DoubleFirstAggregationTest.java @@ -73,8 +73,6 @@ public void testDoubleFirstAggregator() { DoubleFirstAggregator agg = (DoubleFirstAggregator) doubleFirstAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); @@ -126,8 +124,6 @@ public void testDoubleFirstCombiningAggregator() { DoubleFirstAggregator agg = (DoubleFirstAggregator) combiningAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); diff --git a/processing/src/test/java/io/druid/query/aggregation/first/LongFirstAggregationTest.java b/processing/src/test/java/io/druid/query/aggregation/first/LongFirstAggregationTest.java index d95b75f5a991..7ec005884251 100644 --- a/processing/src/test/java/io/druid/query/aggregation/first/LongFirstAggregationTest.java +++ b/processing/src/test/java/io/druid/query/aggregation/first/LongFirstAggregationTest.java @@ -72,8 +72,6 @@ public void testLongFirstAggregator() { LongFirstAggregator agg = (LongFirstAggregator) longFirstAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); @@ -125,8 +123,6 @@ public void testLongFirstCombiningAggregator() { LongFirstAggregator agg = (LongFirstAggregator) combiningAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); diff --git a/processing/src/test/java/io/druid/query/aggregation/last/DoubleLastAggregationTest.java b/processing/src/test/java/io/druid/query/aggregation/last/DoubleLastAggregationTest.java index ffc1e553a1b9..289aa6f09bc7 100644 --- a/processing/src/test/java/io/druid/query/aggregation/last/DoubleLastAggregationTest.java +++ b/processing/src/test/java/io/druid/query/aggregation/last/DoubleLastAggregationTest.java @@ -73,8 +73,6 @@ public void testDoubleLastAggregator() { DoubleLastAggregator agg = (DoubleLastAggregator) doubleLastAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); @@ -126,8 +124,6 @@ public void testDoubleLastCombiningAggregator() { DoubleLastAggregator agg = (DoubleLastAggregator) combiningAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); diff --git a/processing/src/test/java/io/druid/query/aggregation/last/LongLastAggregationTest.java b/processing/src/test/java/io/druid/query/aggregation/last/LongLastAggregationTest.java index 3c95b9fd9817..7353d7a5054f 100644 --- a/processing/src/test/java/io/druid/query/aggregation/last/LongLastAggregationTest.java +++ b/processing/src/test/java/io/druid/query/aggregation/last/LongLastAggregationTest.java @@ -72,8 +72,6 @@ public void testLongLastAggregator() { LongLastAggregator agg = (LongLastAggregator) longLastAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); @@ -125,8 +123,6 @@ public void testLongLastCombiningAggregator() { LongLastAggregator agg = (LongLastAggregator) combiningAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg);