/* * 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.index.rankeval; import org.opensearch.core.ParseField; import org.opensearch.core.common.io.stream.StreamInput; import org.opensearch.core.common.io.stream.StreamOutput; import org.opensearch.core.common.io.stream.Writeable; import org.opensearch.core.xcontent.ConstructingObjectParser; import org.opensearch.core.xcontent.ObjectParser.ValueType; import org.opensearch.core.xcontent.ToXContent; import org.opensearch.core.xcontent.ToXContentObject; import org.opensearch.core.xcontent.XContentBuilder; import org.opensearch.core.xcontent.XContentParser; import org.opensearch.search.SearchHit; import java.io.IOException; import java.util.Objects; import java.util.OptionalInt; /** * Combines a {@link SearchHit} with a document rating. */ public class RatedSearchHit implements Writeable, ToXContentObject { private final SearchHit searchHit; private final OptionalInt rating; public RatedSearchHit(SearchHit searchHit, OptionalInt rating) { this.searchHit = searchHit; this.rating = rating; } RatedSearchHit(StreamInput in) throws IOException { this(new SearchHit(in), in.readBoolean() ? OptionalInt.of(in.readVInt()) : OptionalInt.empty()); } @Override public void writeTo(StreamOutput out) throws IOException { searchHit.writeTo(out); out.writeBoolean(rating.isPresent()); if (rating.isPresent()) { out.writeVInt(rating.getAsInt()); } } public SearchHit getSearchHit() { return this.searchHit; } public OptionalInt getRating() { return this.rating; } @Override public XContentBuilder toXContent(XContentBuilder builder, ToXContent.Params params) throws IOException { builder.startObject(); builder.field("hit", (ToXContent) searchHit); builder.field("rating", rating.isPresent() ? rating.getAsInt() : null); builder.endObject(); return builder; } private static final ParseField HIT_FIELD = new ParseField("hit"); private static final ParseField RATING_FIELD = new ParseField("rating"); private static final ConstructingObjectParser PARSER = new ConstructingObjectParser<>( "rated_hit", true, a -> new RatedSearchHit((SearchHit) a[0], (OptionalInt) a[1]) ); static { PARSER.declareObject(ConstructingObjectParser.constructorArg(), (p, c) -> SearchHit.fromXContent(p), HIT_FIELD); PARSER.declareField( ConstructingObjectParser.constructorArg(), (p) -> p.currentToken() == XContentParser.Token.VALUE_NULL ? OptionalInt.empty() : OptionalInt.of(p.intValue()), RATING_FIELD, ValueType.INT_OR_NULL ); } public static RatedSearchHit parse(XContentParser parser) throws IOException { return PARSER.apply(parser, null); } @Override public final boolean equals(Object obj) { if (this == obj) { return true; } if (obj == null || getClass() != obj.getClass()) { return false; } RatedSearchHit other = (RatedSearchHit) obj; return Objects.equals(rating, other.rating) && Objects.equals(searchHit, other.searchHit); } @Override public final int hashCode() { return Objects.hash(rating, searchHit); } }