bwc in transport stream

Signed-off-by: bowenlan-amzn <bowenlan23@gmail.com>
opensearch-project · Jul 29, 2024 · 577e6d0 · 577e6d0
1 parent b388d59
commit 577e6d0
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 4 deletions.
diff --git a/server/src/main/java/org/opensearch/index/query/TermsQueryBuilder.java b/server/src/main/java/org/opensearch/index/query/TermsQueryBuilder.java
@@ -37,6 +37,7 @@
 import org.apache.lucene.search.Query;
 import org.apache.lucene.util.BytesRef;
 import org.apache.lucene.util.BytesRefBuilder;
+import org.opensearch.Version;
 import org.opensearch.action.get.GetRequest;
 import org.opensearch.client.Client;
 import org.opensearch.common.SetOnce;
@@ -80,14 +81,14 @@
 public class TermsQueryBuilder extends AbstractQueryBuilder<TermsQueryBuilder> {
     public static final String NAME = "terms";
 
-
     private final String fieldName;
     private final List<?> values;
     private final TermsLookup termsLookup;
     private final Supplier<List<?>> supplier;
 
     private static final ParseField VALUE_TYPE_FIELD = new ParseField("value_type");
     private String valueType;
+
     public final TermsQueryBuilder valueType(String valueType) {
         this.valueType = valueType;
         return this;
@@ -199,8 +200,8 @@ public TermsQueryBuilder(String fieldName, Iterable<?> values) {
     }
 
     private TermsQueryBuilder(String fieldName, Iterable<?> values, String valueType) {
-       this(fieldName, values);
-       this.valueType = valueType;
+        this(fieldName, values);
+        this.valueType = valueType;
     }
 
     private TermsQueryBuilder(String fieldName, Supplier<List<?>> supplier) {
@@ -224,6 +225,9 @@ public TermsQueryBuilder(StreamInput in) throws IOException {
         termsLookup = in.readOptionalWriteable(TermsLookup::new);
         values = (List<?>) in.readGenericValue();
         this.supplier = null;
+        if (in.getVersion().after(Version.V_2_16_0)) {
+            valueType = in.readOptionalString();
+        }
     }
 
     @Override
@@ -234,6 +238,9 @@ protected void doWriteTo(StreamOutput out) throws IOException {
         out.writeString(fieldName);
         out.writeOptionalWriteable(termsLookup);
         out.writeGenericValue(values);
+        if (out.getVersion().after(Version.V_2_16_0)) {
+            out.writeOptionalString(valueType);
+        }
     }
 
     public String fieldName() {

diff --git a/server/src/main/java/org/opensearch/indices/TermsLookup.java b/server/src/main/java/org/opensearch/indices/TermsLookup.java
@@ -87,6 +87,9 @@ public TermsLookup(StreamInput in) throws IOException {
         path = in.readString();
         index = in.readString();
         routing = in.readOptionalString();
+        if (in.getVersion().after(Version.V_2_16_0)) {
+            store = in.readBoolean();
+        }
     }
 
     @Override
@@ -98,6 +101,9 @@ public void writeTo(StreamOutput out) throws IOException {
         out.writeString(path);
         out.writeString(index);
         out.writeOptionalString(routing);
+        if (out.getVersion().after(Version.V_2_16_0)) {
+            out.writeBoolean(store);
+        }
     }
 
     public String index() {
@@ -122,7 +128,11 @@ public TermsLookup routing(String routing) {
     }
 
     private boolean store;
-    public boolean store() { return store; }
+
+    public boolean store() {
+        return store;
+    }
+
     public TermsLookup store(boolean store) {
         this.store = store;
         return this;