/* * SPDX-License-Identifier: Apache-2.0 * * The OpenSearch Contributors require contributions made to * this file be licensed under the Apache-2.0 license or a * compatible open source license. */ /* * Licensed to Elasticsearch under one or more contributor * license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright * ownership. Elasticsearch licenses this file to you under * the Apache License, Version 2.0 (the "License"); you may * not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ /* * Modifications Copyright OpenSearch Contributors. See * GitHub history for details. */ package org.opensearch.search.aggregations.metrics; import org.opensearch.core.ParseField; import org.opensearch.core.common.io.stream.StreamInput; import org.opensearch.core.xcontent.ConstructingObjectParser; import org.opensearch.core.xcontent.XContentParser; import org.opensearch.index.query.QueryShardContext; import org.opensearch.search.aggregations.AggregationBuilder; import org.opensearch.search.aggregations.AggregatorFactories; import org.opensearch.search.aggregations.AggregatorFactory; import org.opensearch.search.aggregations.support.CoreValuesSourceType; import org.opensearch.search.aggregations.support.ValuesSourceAggregatorFactory; import org.opensearch.search.aggregations.support.ValuesSourceConfig; import org.opensearch.search.aggregations.support.ValuesSourceRegistry; import org.opensearch.search.aggregations.support.ValuesSourceType; import java.io.IOException; import java.util.Map; /** * Aggregation Builder for percentile_ranks agg * * @opensearch.internal */ public class PercentileRanksAggregationBuilder extends AbstractPercentilesAggregationBuilder { public static final String NAME = PercentileRanks.TYPE_NAME; public static final ValuesSourceRegistry.RegistryKey REGISTRY_KEY = new ValuesSourceRegistry.RegistryKey<>(NAME, PercentilesAggregatorSupplier.class); private static final ParseField VALUES_FIELD = new ParseField("values"); private static final ConstructingObjectParser PARSER; static { PARSER = AbstractPercentilesAggregationBuilder.createParser( PercentileRanksAggregationBuilder.NAME, PercentileRanksAggregationBuilder::new, PercentilesConfig.TDigest::new, VALUES_FIELD ); } public static AggregationBuilder parse(String aggregationName, XContentParser parser) throws IOException { return PARSER.parse(parser, aggregationName); } public static void registerAggregators(ValuesSourceRegistry.Builder builder) { PercentileRanksAggregatorFactory.registerAggregators(builder); } public PercentileRanksAggregationBuilder(String name, double[] values) { this(name, values, null); } private PercentileRanksAggregationBuilder(String name, double[] values, PercentilesConfig percentilesConfig) { super(name, values, percentilesConfig, VALUES_FIELD); } public PercentileRanksAggregationBuilder(StreamInput in) throws IOException { super(in, VALUES_FIELD); } private PercentileRanksAggregationBuilder( PercentileRanksAggregationBuilder clone, AggregatorFactories.Builder factoriesBuilder, Map metadata ) { super(clone, factoriesBuilder, metadata); } @Override protected AggregationBuilder shallowCopy(AggregatorFactories.Builder factoriesBuilder, Map metadata) { return new PercentileRanksAggregationBuilder(this, factoriesBuilder, metadata); } @Override protected ValuesSourceType defaultValueSourceType() { return CoreValuesSourceType.NUMERIC; } /** * Get the values to compute percentiles from. */ public double[] values() { return values; } @Override protected ValuesSourceAggregatorFactory innerBuild( QueryShardContext queryShardContext, ValuesSourceConfig config, AggregatorFactory parent, AggregatorFactories.Builder subFactoriesBuilder ) throws IOException { return new PercentileRanksAggregatorFactory( name, config, values, configOrDefault(), keyed, queryShardContext, parent, subFactoriesBuilder, metadata ); } @Override public String getType() { return NAME; } @Override protected ValuesSourceRegistry.RegistryKey getRegistryKey() { return REGISTRY_KEY; } }