Add @experimentalapi annotation

Signed-off-by: Rishabh Maurya <[email protected]>

Author: rishabhmaurya

CHANGELOG.md

@@ -38,6 +38,8 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 - Add support for Combined Fields query ([#18724](https://github.com/opensearch-project/OpenSearch/pull/18724))
 - Added approximation support for range queries with now in date field ([#18511](https://github.com/opensearch-project/OpenSearch/pull/18511))
 - Streaming transport and new stream based search action ([#18722](https://github.com/opensearch-project/OpenSearch/pull/18722))
+- Upgrade to protobufs 0.6.0 and clean up deprecated TermQueryProtoUtils code ([#18880](https://github.com/opensearch-project/OpenSearch/pull/18880))
+- APIs for stream transport and new stream-based search api action ([#18722](https://github.com/opensearch-project/OpenSearch/pull/18722))
 
 ### Changed
 - Update Subject interface to use CheckedRunnable ([#18570](https://github.com/opensearch-project/OpenSearch/issues/18570))

server/src/main/java/org/opensearch/action/search/StreamSearchTransportService.java

@@ -36,6 +36,8 @@
 
 /**
  * Search transport service for streaming search
+ *
+ * @opensearch.internal
  */
 public class StreamSearchTransportService extends SearchTransportService {
     private final StreamTransportService transportService;

server/src/main/java/org/opensearch/action/support/StreamChannelActionListener.java

@@ -8,6 +8,7 @@
 
 package org.opensearch.action.support;
 
+import org.opensearch.common.annotation.ExperimentalApi;
 import org.opensearch.core.action.ActionListener;
 import org.opensearch.core.transport.TransportResponse;
 import org.opensearch.transport.TransportChannel;
@@ -18,8 +19,8 @@
 /**
  * A listener that sends the response back to the channel in streaming fashion
  *
- * @opensearch.internal
  */
+@ExperimentalApi
 public class StreamChannelActionListener<Response extends TransportResponse, Request extends TransportRequest>
     implements
         ActionListener<Response> {

server/src/main/java/org/opensearch/transport/StreamTransportResponseHandler.java

@@ -8,7 +8,7 @@
 
 package org.opensearch.transport;
 
-import org.opensearch.common.annotation.PublicApi;
+import org.opensearch.common.annotation.ExperimentalApi;
 import org.opensearch.core.transport.TransportResponse;
 import org.opensearch.transport.stream.StreamTransportResponse;
 
@@ -44,7 +44,7 @@
  *
  * @opensearch.api
  */
-@PublicApi(since = "1.0.0")
+@ExperimentalApi
 public interface StreamTransportResponseHandler<T extends TransportResponse> extends TransportResponseHandler<T> {
 
     /**

server/src/main/java/org/opensearch/transport/TransportChannel.java

@@ -36,6 +36,7 @@
 import org.apache.logging.log4j.Logger;
 import org.apache.logging.log4j.message.ParameterizedMessage;
 import org.opensearch.Version;
+import org.opensearch.common.annotation.ExperimentalApi;
 import org.opensearch.common.annotation.PublicApi;
 import org.opensearch.core.transport.TransportResponse;
 import org.opensearch.transport.stream.StreamErrorCode;
@@ -68,6 +69,7 @@ public interface TransportChannel {
      * @throws StreamException with {@link StreamErrorCode#CANCELLED} if the stream has been canceled.
      * Do not call this method again or completeStream() once canceled.
      */
+    @ExperimentalApi
     default void sendResponseBatch(TransportResponse response) {
         throw new UnsupportedOperationException();
     }
@@ -76,6 +78,7 @@ default void sendResponseBatch(TransportResponse response) {
      * Call this method on a successful completion the streaming response.
      * Note: not calling this method on success will result in a memory leak
      */
+    @ExperimentalApi
     default void completeStream() {
         throw new UnsupportedOperationException();
     }

server/src/main/java/org/opensearch/transport/TransportMessageListener.java

@@ -32,6 +32,7 @@
 package org.opensearch.transport;
 
 import org.opensearch.cluster.node.DiscoveryNode;
+import org.opensearch.common.annotation.ExperimentalApi;
 import org.opensearch.common.annotation.PublicApi;
 import org.opensearch.core.transport.TransportResponse;
 import org.opensearch.transport.stream.StreamTransportResponse;
@@ -63,6 +64,7 @@ default void onRequestReceived(long requestId, String action) {}
      */
     default void onResponseSent(long requestId, String action, TransportResponse response) {}
 
+    @ExperimentalApi
     default void onStreamResponseSent(long requestId, String action, StreamTransportResponse response) {}
 
     /***

server/src/main/java/org/opensearch/transport/TransportResponseHandler.java

@@ -32,6 +32,7 @@
 
 package org.opensearch.transport;
 
+import org.opensearch.common.annotation.ExperimentalApi;
 import org.opensearch.common.annotation.PublicApi;
 import org.opensearch.core.common.io.stream.StreamInput;
 import org.opensearch.core.common.io.stream.Writeable;
@@ -85,6 +86,7 @@ public interface TransportResponseHandler<T extends TransportResponse> extends W
      *
      * @param response the streaming response, which must be closed by the handler
      */
+    @ExperimentalApi
     default void handleStreamResponse(StreamTransportResponse<T> response) {
         throw new UnsupportedOperationException("Streaming responses not supported by this handler");
     }

server/src/main/java/org/opensearch/transport/stream/StreamErrorCode.java

@@ -8,13 +8,15 @@
 
 package org.opensearch.transport.stream;
 
+import org.opensearch.common.annotation.ExperimentalApi;
+
 /**
  * Error codes for streaming transport operations, inspired by gRPC and Arrow Flight error codes.
  * These codes provide standardized error categories for stream-based transports
  * like Arrow Flight RPC.
  *
- * @opensearch.internal
  */
+@ExperimentalApi
 public enum StreamErrorCode {
     /**
      * Operation completed successfully.

server/src/main/java/org/opensearch/transport/stream/StreamException.java

@@ -8,6 +8,7 @@
 
 package org.opensearch.transport.stream;
 
+import org.opensearch.common.annotation.ExperimentalApi;
 import org.opensearch.core.common.io.stream.StreamInput;
 import org.opensearch.core.common.io.stream.StreamOutput;
 import org.opensearch.transport.TransportException;
@@ -19,8 +20,8 @@
  * Exception for streaming transport operations with standardized error codes.
  * This provides a consistent error model for stream-based transports like Arrow Flight RPC.
  *
- * @opensearch.internal
  */
+@ExperimentalApi
 public class StreamException extends TransportException {
 
     private final StreamErrorCode errorCode;

server/src/main/java/org/opensearch/transport/stream/StreamingTransportChannel.java

@@ -8,6 +8,7 @@
 
 package org.opensearch.transport.stream;
 
+import org.opensearch.common.annotation.ExperimentalApi;
 import org.opensearch.core.transport.TransportResponse;
 import org.opensearch.transport.TransportChannel;
 
@@ -22,8 +23,8 @@
  * {@link StreamErrorCode#CANCELLED}.
  * At this point, no action is needed as the underlying channel is already closed and call to
  * completeStream() will fail.
- * @opensearch.internal
  */
+@ExperimentalApi
 public interface StreamingTransportChannel extends TransportChannel {
 
     // TODO: introduce a way to poll for cancellation in addition to current way of detection i.e. depending on channel