Skip to content

Commit d2b27d9

Browse files
authored
Rename AggregateDoubleMetric to *MetricDouble (#121254) (#121703)
Some areas of the code call this field type AggregateDoubleMetric and others AggregateMetricDouble, but the docs use aggregate_metric_double, so for consistency this commit refactors the former into the latter.
1 parent 76c88aa commit d2b27d9

22 files changed

+124
-124
lines changed

x-pack/plugin/downsample/src/main/java/org/elasticsearch/xpack/downsample/AggregateMetricFieldValueFetcher.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -10,18 +10,18 @@
1010
import org.elasticsearch.index.fielddata.IndexFieldData;
1111
import org.elasticsearch.index.mapper.MappedFieldType;
1212
import org.elasticsearch.index.mapper.NumberFieldMapper;
13-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper;
14-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper.AggregateDoubleMetricFieldType;
13+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper;
14+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper.AggregateMetricDoubleFieldType;
1515

1616
public final class AggregateMetricFieldValueFetcher extends FieldValueFetcher {
1717

18-
private final AggregateDoubleMetricFieldType aggMetricFieldType;
18+
private final AggregateMetricDoubleFieldType aggMetricFieldType;
1919

2020
private final AbstractDownsampleFieldProducer fieldProducer;
2121

2222
AggregateMetricFieldValueFetcher(
2323
MappedFieldType fieldType,
24-
AggregateDoubleMetricFieldType aggMetricFieldType,
24+
AggregateMetricDoubleFieldType aggMetricFieldType,
2525
IndexFieldData<?> fieldData
2626
) {
2727
super(fieldType.name(), fieldType, fieldData);
@@ -34,7 +34,7 @@ public AbstractDownsampleFieldProducer fieldProducer() {
3434
}
3535

3636
private AbstractDownsampleFieldProducer createFieldProducer() {
37-
AggregateDoubleMetricFieldMapper.Metric metric = null;
37+
AggregateMetricDoubleFieldMapper.Metric metric = null;
3838
for (var e : aggMetricFieldType.getMetricFields().entrySet()) {
3939
NumberFieldMapper.NumberFieldType metricSubField = e.getValue();
4040
if (metricSubField.name().equals(name())) {
@@ -52,7 +52,7 @@ private AbstractDownsampleFieldProducer createFieldProducer() {
5252
case min -> new MetricFieldProducer.Min();
5353
case sum -> new MetricFieldProducer.Sum();
5454
// To compute value_count summary, we must sum all field values
55-
case value_count -> new MetricFieldProducer.Sum(AggregateDoubleMetricFieldMapper.Metric.value_count.name());
55+
case value_count -> new MetricFieldProducer.Sum(AggregateMetricDoubleFieldMapper.Metric.value_count.name());
5656
};
5757
return new MetricFieldProducer.GaugeMetricFieldProducer(aggMetricFieldType.name(), metricOperation);
5858
} else {

x-pack/plugin/downsample/src/main/java/org/elasticsearch/xpack/downsample/FieldValueFetcher.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
import org.elasticsearch.index.mapper.flattened.FlattenedFieldMapper;
1616
import org.elasticsearch.index.query.SearchExecutionContext;
1717
import org.elasticsearch.search.DocValueFormat;
18-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper;
18+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper;
1919

2020
import java.util.ArrayList;
2121
import java.util.Collections;
@@ -82,7 +82,7 @@ static List<FieldValueFetcher> create(SearchExecutionContext context, String[] f
8282
MappedFieldType fieldType = context.getFieldType(field);
8383
assert fieldType != null : "Unknown field type for field: [" + field + "]";
8484

85-
if (fieldType instanceof AggregateDoubleMetricFieldMapper.AggregateDoubleMetricFieldType aggMetricFieldType) {
85+
if (fieldType instanceof AggregateMetricDoubleFieldMapper.AggregateMetricDoubleFieldType aggMetricFieldType) {
8686
// If the field is an aggregate_metric_double field, we should load all its subfields
8787
// This is a downsample-of-downsample case
8888
for (NumberFieldMapper.NumberFieldType metricSubField : aggMetricFieldType.getMetricFields().values()) {

x-pack/plugin/downsample/src/main/java/org/elasticsearch/xpack/downsample/LabelFieldProducer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
import org.elasticsearch.index.fielddata.HistogramValue;
1313
import org.elasticsearch.index.mapper.flattened.FlattenedFieldSyntheticWriterHelper;
1414
import org.elasticsearch.xcontent.XContentBuilder;
15-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper.Metric;
15+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper.Metric;
1616

1717
import java.io.IOException;
1818
import java.util.ArrayList;

x-pack/plugin/downsample/src/main/java/org/elasticsearch/xpack/downsample/TransportDownsampleAction.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@
7676
import org.elasticsearch.xcontent.XContentBuilder;
7777
import org.elasticsearch.xcontent.XContentFactory;
7878
import org.elasticsearch.xcontent.XContentType;
79-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper;
79+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper;
8080
import org.elasticsearch.xpack.core.ClientHelper;
8181
import org.elasticsearch.xpack.core.downsample.DownsampleShardPersistentTaskState;
8282
import org.elasticsearch.xpack.core.downsample.DownsampleShardTask;
@@ -755,9 +755,9 @@ private static void addMetricFieldMapping(final XContentBuilder builder, final S
755755
final String[] supportedAggsArray = metricType.supportedAggs();
756756
// We choose max as the default metric
757757
final String defaultMetric = List.of(supportedAggsArray).contains("max") ? "max" : supportedAggsArray[0];
758-
builder.field("type", AggregateDoubleMetricFieldMapper.CONTENT_TYPE)
759-
.array(AggregateDoubleMetricFieldMapper.Names.METRICS, supportedAggsArray)
760-
.field(AggregateDoubleMetricFieldMapper.Names.DEFAULT_METRIC, defaultMetric)
758+
builder.field("type", AggregateMetricDoubleFieldMapper.CONTENT_TYPE)
759+
.array(AggregateMetricDoubleFieldMapper.Names.METRICS, supportedAggsArray)
760+
.field(AggregateMetricDoubleFieldMapper.Names.DEFAULT_METRIC, defaultMetric)
761761
.field(TIME_SERIES_METRIC_PARAM, metricType);
762762
}
763763
builder.endObject();

x-pack/plugin/mapper-aggregate-metric/src/main/java/org/elasticsearch/xpack/aggregatemetric/AggregateMetricMapperPlugin.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
import org.elasticsearch.plugins.SearchPlugin;
1818
import org.elasticsearch.search.aggregations.support.ValuesSourceRegistry;
1919
import org.elasticsearch.xpack.aggregatemetric.aggregations.metrics.AggregateMetricsAggregatorsRegistrar;
20-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper;
20+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper;
2121
import org.elasticsearch.xpack.core.action.XPackInfoFeatureAction;
2222
import org.elasticsearch.xpack.core.action.XPackUsageFeatureAction;
2323

@@ -32,7 +32,7 @@ public class AggregateMetricMapperPlugin extends Plugin implements MapperPlugin,
3232

3333
@Override
3434
public Map<String, Mapper.TypeParser> getMappers() {
35-
return singletonMap(AggregateDoubleMetricFieldMapper.CONTENT_TYPE, AggregateDoubleMetricFieldMapper.PARSER);
35+
return singletonMap(AggregateMetricDoubleFieldMapper.CONTENT_TYPE, AggregateMetricDoubleFieldMapper.PARSER);
3636
}
3737

3838
@Override

x-pack/plugin/mapper-aggregate-metric/src/main/java/org/elasticsearch/xpack/aggregatemetric/aggregations/metrics/AggregateMetricBackedAvgAggregator.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,14 +24,14 @@
2424
import org.elasticsearch.search.aggregations.support.AggregationContext;
2525
import org.elasticsearch.search.aggregations.support.ValuesSourceConfig;
2626
import org.elasticsearch.xpack.aggregatemetric.aggregations.support.AggregateMetricsValuesSource;
27-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper.Metric;
27+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper.Metric;
2828

2929
import java.io.IOException;
3030
import java.util.Map;
3131

3232
class AggregateMetricBackedAvgAggregator extends NumericMetricsAggregator.SingleValue {
3333

34-
final AggregateMetricsValuesSource.AggregateDoubleMetric valuesSource;
34+
final AggregateMetricsValuesSource.AggregateMetricDouble valuesSource;
3535

3636
LongArray counts;
3737
DoubleArray sums;
@@ -47,7 +47,7 @@ class AggregateMetricBackedAvgAggregator extends NumericMetricsAggregator.Single
4747
) throws IOException {
4848
super(name, context, parent, metadata);
4949
assert valuesSourceConfig.hasValues();
50-
this.valuesSource = (AggregateMetricsValuesSource.AggregateDoubleMetric) valuesSourceConfig.getValuesSource();
50+
this.valuesSource = (AggregateMetricsValuesSource.AggregateMetricDouble) valuesSourceConfig.getValuesSource();
5151
final BigArrays bigArrays = context.bigArrays();
5252
counts = bigArrays.newLongArray(1, true);
5353
sums = bigArrays.newDoubleArray(1, true);

x-pack/plugin/mapper-aggregate-metric/src/main/java/org/elasticsearch/xpack/aggregatemetric/aggregations/metrics/AggregateMetricBackedMaxAggregator.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,14 +24,14 @@
2424
import org.elasticsearch.search.aggregations.support.AggregationContext;
2525
import org.elasticsearch.search.aggregations.support.ValuesSourceConfig;
2626
import org.elasticsearch.xpack.aggregatemetric.aggregations.support.AggregateMetricsValuesSource;
27-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper.Metric;
27+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper.Metric;
2828

2929
import java.io.IOException;
3030
import java.util.Map;
3131

3232
class AggregateMetricBackedMaxAggregator extends NumericMetricsAggregator.SingleValue {
3333

34-
private final AggregateMetricsValuesSource.AggregateDoubleMetric valuesSource;
34+
private final AggregateMetricsValuesSource.AggregateMetricDouble valuesSource;
3535
final DocValueFormat formatter;
3636
DoubleArray maxes;
3737

@@ -44,7 +44,7 @@ class AggregateMetricBackedMaxAggregator extends NumericMetricsAggregator.Single
4444
) throws IOException {
4545
super(name, context, parent, metadata);
4646
assert config.hasValues();
47-
this.valuesSource = (AggregateMetricsValuesSource.AggregateDoubleMetric) config.getValuesSource();
47+
this.valuesSource = (AggregateMetricsValuesSource.AggregateMetricDouble) config.getValuesSource();
4848
maxes = context.bigArrays().newDoubleArray(1, false);
4949
maxes.fill(0, maxes.size(), Double.NEGATIVE_INFINITY);
5050
this.formatter = config.format();

x-pack/plugin/mapper-aggregate-metric/src/main/java/org/elasticsearch/xpack/aggregatemetric/aggregations/metrics/AggregateMetricBackedMinAggregator.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,14 +24,14 @@
2424
import org.elasticsearch.search.aggregations.support.AggregationContext;
2525
import org.elasticsearch.search.aggregations.support.ValuesSourceConfig;
2626
import org.elasticsearch.xpack.aggregatemetric.aggregations.support.AggregateMetricsValuesSource;
27-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper.Metric;
27+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper.Metric;
2828

2929
import java.io.IOException;
3030
import java.util.Map;
3131

3232
class AggregateMetricBackedMinAggregator extends NumericMetricsAggregator.SingleValue {
3333

34-
private final AggregateMetricsValuesSource.AggregateDoubleMetric valuesSource;
34+
private final AggregateMetricsValuesSource.AggregateMetricDouble valuesSource;
3535
final DocValueFormat format;
3636
DoubleArray mins;
3737

@@ -44,7 +44,7 @@ class AggregateMetricBackedMinAggregator extends NumericMetricsAggregator.Single
4444
) throws IOException {
4545
super(name, context, parent, metadata);
4646
assert config.hasValues();
47-
this.valuesSource = (AggregateMetricsValuesSource.AggregateDoubleMetric) config.getValuesSource();
47+
this.valuesSource = (AggregateMetricsValuesSource.AggregateMetricDouble) config.getValuesSource();
4848
mins = context.bigArrays().newDoubleArray(1, false);
4949
mins.fill(0, mins.size(), Double.POSITIVE_INFINITY);
5050
this.format = config.format();

x-pack/plugin/mapper-aggregate-metric/src/main/java/org/elasticsearch/xpack/aggregatemetric/aggregations/metrics/AggregateMetricBackedSumAggregator.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,14 +23,14 @@
2323
import org.elasticsearch.search.aggregations.support.AggregationContext;
2424
import org.elasticsearch.search.aggregations.support.ValuesSourceConfig;
2525
import org.elasticsearch.xpack.aggregatemetric.aggregations.support.AggregateMetricsValuesSource;
26-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper.Metric;
26+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper.Metric;
2727

2828
import java.io.IOException;
2929
import java.util.Map;
3030

3131
class AggregateMetricBackedSumAggregator extends NumericMetricsAggregator.SingleValue {
3232

33-
private final AggregateMetricsValuesSource.AggregateDoubleMetric valuesSource;
33+
private final AggregateMetricsValuesSource.AggregateMetricDouble valuesSource;
3434
private final DocValueFormat format;
3535

3636
private DoubleArray sums;
@@ -45,7 +45,7 @@ class AggregateMetricBackedSumAggregator extends NumericMetricsAggregator.Single
4545
) throws IOException {
4646
super(name, context, parent, metadata);
4747
assert valuesSourceConfig.hasValues();
48-
this.valuesSource = (AggregateMetricsValuesSource.AggregateDoubleMetric) valuesSourceConfig.getValuesSource();
48+
this.valuesSource = (AggregateMetricsValuesSource.AggregateMetricDouble) valuesSourceConfig.getValuesSource();
4949
sums = context.bigArrays().newDoubleArray(1, true);
5050
compensations = context.bigArrays().newDoubleArray(1, true);
5151
this.format = valuesSourceConfig.format();

x-pack/plugin/mapper-aggregate-metric/src/main/java/org/elasticsearch/xpack/aggregatemetric/aggregations/metrics/AggregateMetricBackedValueCountAggregator.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
import org.elasticsearch.search.aggregations.support.AggregationContext;
2121
import org.elasticsearch.search.aggregations.support.ValuesSourceConfig;
2222
import org.elasticsearch.xpack.aggregatemetric.aggregations.support.AggregateMetricsValuesSource;
23-
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateDoubleMetricFieldMapper;
23+
import org.elasticsearch.xpack.aggregatemetric.mapper.AggregateMetricDoubleFieldMapper;
2424

2525
import java.io.IOException;
2626
import java.util.Map;
@@ -32,7 +32,7 @@
3232
*/
3333
class AggregateMetricBackedValueCountAggregator extends NumericMetricsAggregator.SingleValue {
3434

35-
private final AggregateMetricsValuesSource.AggregateDoubleMetric valuesSource;
35+
private final AggregateMetricsValuesSource.AggregateMetricDouble valuesSource;
3636

3737
// a count per bucket
3838
LongArray counts;
@@ -46,7 +46,7 @@ class AggregateMetricBackedValueCountAggregator extends NumericMetricsAggregator
4646
) throws IOException {
4747
super(name, aggregationContext, parent, metadata);
4848
assert valuesSourceConfig.hasValues();
49-
this.valuesSource = (AggregateMetricsValuesSource.AggregateDoubleMetric) valuesSourceConfig.getValuesSource();
49+
this.valuesSource = (AggregateMetricsValuesSource.AggregateMetricDouble) valuesSourceConfig.getValuesSource();
5050
counts = bigArrays().newLongArray(1, true);
5151
}
5252

@@ -55,7 +55,7 @@ public LeafBucketCollector getLeafCollector(AggregationExecutionContext aggCtx,
5555
final BigArrays bigArrays = bigArrays();
5656
final SortedNumericDoubleValues values = valuesSource.getAggregateMetricValues(
5757
aggCtx.getLeafReaderContext(),
58-
AggregateDoubleMetricFieldMapper.Metric.value_count
58+
AggregateMetricDoubleFieldMapper.Metric.value_count
5959
);
6060

6161
return new LeafBucketCollectorBase(sub, values) {

0 commit comments

Comments
 (0)