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 880ab0b2aae..dad32587f09 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 class DistinctCountAggregator implements Aggregator 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 9060a60f8e4..1655eb42225 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 class EmptyDistinctCountAggregator implements Aggregator 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 4d9d59bae83..1dcdc3c99c6 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 class TimestampAggregator implements Aggregator 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 ae62b767830..c97e313be99 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 class TimestampAggregatorFactory extends AggregatorFactory 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 00823aaafc0..b74f56ce40c 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 class TimestampMinMaxAggregatorTest { 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 be197352ca9..f100e9ec14e 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 class EmptySketchAggregator implements Aggregator 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 a7944df19dd..39f16a528a8 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 class SketchAggregator implements Aggregator 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 b66b156a268..988c3049d0f 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 class ApproximateHistogramAggregator implements Aggregator 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 1c2bed00e6c..04ef463d662 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 class ApproximateHistogramFoldingAggregator implements Aggregator 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 e335bd348bd..9fa7eba99f3 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 abstract class VarianceAggregator implements Aggregator 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/Aggregator.java b/processing/src/main/java/io/druid/query/aggregation/Aggregator.java index c60902bfbb8..95495ddea53 100644 --- a/processing/src/main/java/io/druid/query/aggregation/Aggregator.java +++ b/processing/src/main/java/io/druid/query/aggregation/Aggregator.java @@ -38,10 +38,6 @@ public interface Aggregator { Object get(); float getFloat(); - /** - * Deprecated, to be removed in 0.10.0. See https://github.com/druid-io/druid/issues/3588. - */ - @Deprecated String getName(); void close(); long getLong(); 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 2bdc2b2298e..083841e3dd0 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 abstract class AggregatorFactory */ 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 41d70fb3092..068784d8d6e 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 class Aggregators 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 8ef34690efb..b40b9186b73 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 class CountAggregator implements Aggregator 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 843bcc5a987..1c5f5fc960e 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 class DoubleMaxAggregator implements Aggregator 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 e0f4fc519a6..f72efa55ed7 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 class DoubleMinAggregator implements Aggregator 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 93acc564266..bb293527d63 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 class DoubleSumAggregator implements Aggregator 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 b3e1f57b273..1c92d3c9992 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 class FilteredAggregator implements Aggregator 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 d289c46ffda..bb37bd006d1 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 class HistogramAggregator implements Aggregator 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 5adb021363d..ca1d0e57e95 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 class JavaScriptAggregator implements Aggregator 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 4348b8ce0c5..569665624cb 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 class LongMaxAggregator implements Aggregator 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 5e82158f70b..49c8a2243f5 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 class LongMinAggregator implements Aggregator 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 101b0a99f6f..8dc90622ea4 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 class LongSumAggregator implements Aggregator 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 20bc344beeb..4b770c25f8d 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 class CardinalityAggregator implements Aggregator 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 bc709de3913..2a44dbc1e42 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 class DoubleFirstAggregator implements Aggregator 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 192f8c36330..f63c398adb3 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 class DoubleFirstAggregatorFactory extends AggregatorFactory 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 51a5309c73a..1155d1a5efe 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 class LongFirstAggregator implements Aggregator 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 459cf4ac2fb..e1d1f187107 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 class LongFirstAggregatorFactory extends AggregatorFactory 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 86db71f3d6c..194a8670b14 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 class HyperUniquesAggregator implements Aggregator 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 3e72387ea40..c3bc7fb1758 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 class DoubleLastAggregator implements Aggregator 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 302a1cfa791..bacdfc66b19 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 class DoubleLastAggregatorFactory extends AggregatorFactory 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 bc312918eeb..4d18aa14133 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 class LongLastAggregator implements Aggregator 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 481e888bbaa..e4d46815e60 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 class LongLastAggregatorFactory extends AggregatorFactory 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 1e31600cbd1..24c6b084729 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 class DoubleFirstAggregationTest { DoubleFirstAggregator agg = (DoubleFirstAggregator) doubleFirstAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); @@ -126,8 +124,6 @@ public class DoubleFirstAggregationTest { 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 d95b75f5a99..7ec00588425 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 class LongFirstAggregationTest { LongFirstAggregator agg = (LongFirstAggregator) longFirstAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); @@ -125,8 +123,6 @@ public class LongFirstAggregationTest { 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 ffc1e553a1b..289aa6f09bc 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 class DoubleLastAggregationTest { DoubleLastAggregator agg = (DoubleLastAggregator) doubleLastAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); @@ -126,8 +124,6 @@ public class DoubleLastAggregationTest { 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 3c95b9fd981..7353d7a5054 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 class LongLastAggregationTest { LongLastAggregator agg = (LongLastAggregator) longLastAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg); @@ -125,8 +123,6 @@ public class LongLastAggregationTest { LongLastAggregator agg = (LongLastAggregator) combiningAggFactory.factorize(colSelectorFactory); - Assert.assertEquals("billy", agg.getName()); - aggregate(agg); aggregate(agg); aggregate(agg);