Skip to content

Commit 0349803

Browse files
fix tests
1 parent 74f6e0e commit 0349803

File tree

4 files changed

+14
-13
lines changed

4 files changed

+14
-13
lines changed

server/src/main/java/org/elasticsearch/search/aggregations/bucket/SingleBucketAggregation.java

+10-3
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
/**
3535
* A base class for all the single bucket aggregations.
3636
*/
37-
public abstract class SingleBucketAggregation extends InternalAggregation {
37+
public class SingleBucketAggregation extends InternalAggregation {
3838

3939
private final long docCount;
4040
private final InternalAggregations aggregations;
@@ -46,7 +46,7 @@ public abstract class SingleBucketAggregation extends InternalAggregation {
4646
* @param docCount The document count in the single bucket.
4747
* @param aggregations The already built sub-aggregations that are associated with the bucket.
4848
*/
49-
protected SingleBucketAggregation(String name, long docCount, InternalAggregations aggregations, Map<String, Object> metadata) {
49+
public SingleBucketAggregation(String name, long docCount, InternalAggregations aggregations, Map<String, Object> metadata) {
5050
super(name, metadata);
5151
this.docCount = docCount;
5252
this.aggregations = aggregations;
@@ -96,7 +96,9 @@ public SingleBucketAggregation create(InternalAggregations subAggregations) {
9696
/**
9797
* Create a <b>new</b> empty sub aggregation. This must be a new instance on each call.
9898
*/
99-
protected abstract SingleBucketAggregation newAggregation(String name, long docCount, InternalAggregations subAggregations);
99+
protected SingleBucketAggregation newAggregation(String name, long docCount, InternalAggregations subAggregations) {
100+
return new SingleBucketAggregation(name, docCount, subAggregations, metadata);
101+
}
100102

101103
@Override
102104
protected AggregatorReducer getLeaderReducer(AggregationReduceContext reduceContext, int size) {
@@ -225,4 +227,9 @@ public boolean equals(Object obj) {
225227
public int hashCode() {
226228
return Objects.hash(super.hashCode(), docCount, aggregations);
227229
}
230+
231+
@Override
232+
public String getWriteableName() {
233+
return "SingleBucketAggregation";
234+
}
228235
}

server/src/main/java/org/elasticsearch/search/aggregations/bucket/filter/InternalFilter.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
import java.util.Map;
2020

2121
public class InternalFilter extends SingleBucketAggregation {
22-
InternalFilter(String name, long docCount, InternalAggregations subAggregations, Map<String, Object> metadata) {
22+
public InternalFilter(String name, long docCount, InternalAggregations subAggregations, Map<String, Object> metadata) {
2323
super(name, docCount, subAggregations, metadata);
2424
}
2525

x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ml/dataframe/evaluation/MockAggregations.java

+2-4
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
import java.util.Collections;
1919
import java.util.List;
20+
import java.util.Map;
2021

2122
import static org.mockito.Mockito.doReturn;
2223
import static org.mockito.Mockito.mock;
@@ -68,10 +69,7 @@ public static InternalFilters.InternalBucket mockFiltersBucket(String key, long
6869
}
6970

7071
public static InternalFilter mockFilter(String name, long docCount) {
71-
InternalFilter agg = mock(InternalFilter.class);
72-
when(agg.getName()).thenReturn(name);
73-
when(agg.getDocCount()).thenReturn(docCount);
74-
return agg;
72+
return new InternalFilter(name, docCount, InternalAggregations.EMPTY, Map.of());
7573
}
7674

7775
public static InternalNumericMetricsAggregation.SingleValue mockSingleValue(String name, double value) {

x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationTestUtils.java

+1-5
Original file line numberDiff line numberDiff line change
@@ -60,11 +60,7 @@ static InternalComposite.InternalBucket createCompositeBucket(
6060
}
6161

6262
static SingleBucketAggregation createSingleBucketAgg(String name, long docCount, List<InternalAggregation> subAggregations) {
63-
SingleBucketAggregation singleBucketAggregation = mock(SingleBucketAggregation.class);
64-
when(singleBucketAggregation.getName()).thenReturn(name);
65-
when(singleBucketAggregation.getDocCount()).thenReturn(docCount);
66-
when(singleBucketAggregation.getAggregations()).thenReturn(createAggs(subAggregations));
67-
return singleBucketAggregation;
63+
return new SingleBucketAggregation(name, docCount, createAggs(subAggregations), Map.of());
6864
}
6965

7066
static InternalHistogram.Bucket createHistogramBucket(long timestamp, long docCount) {

0 commit comments

Comments
 (0)