chore(javadoc): do not use @APinote in JDK 17

Author: bevzzz

src/main/java/io/weaviate/client6/v1/api/collections/batch/BatchContext.java

@@ -152,24 +152,6 @@ public final class BatchContext<PropertiesT> implements Closeable {
   /** Lightway check to ensure users cannot send on a closed context. */
   private volatile boolean closed;
 
-  // /** Closing state. */
-  // private volatile Closing closing;
-
-  // /**
-  // * setClosing trasitions BatchContext to {@link Closing} state exactly once.
-  // * Once this method returns, the caller can call {@code closing.await()}.
-  // */
-  // void setClosing(Exception ex) {
-  // if (closing == null) {
-  // synchronized (Closing.class) {
-  // if (closing == null) {
-  // closing = new Closing(ex);
-  // setState(closing);
-  // }
-  // }
-  // }
-  // }
-
   BatchContext(
       StreamFactory<Message, Event> streamFactory,
       int maxSizeBytes,
@@ -207,6 +189,7 @@ void start(State nextState) {
     workers = new CountDownLatch(2);
 
     messages = streamFactory.createStream(new Recv());
+    System.out.println("create stream");
 
     // Start the stream and await Started message.
     messages.onNext(Message.start(collectionHandleDefaults.consistencyLevel()));
@@ -654,9 +637,6 @@ private final void onResults(Event.Results results) {
     }
 
     private final void onBackoff(Event.Backoff backoff) {
-      System.out.print("========== BACKOFF ==============");
-      System.out.print(backoff.maxSize());
-      System.out.print("=================================");
       batch.setMaxSize(backoff.maxSize());
     }
 
@@ -840,11 +820,13 @@ private void reconnectNow() {
     /**
      * Schedule a task to {@link #reconnect} after a delay.
      *
-     * @param delaySeconds Delay in seconds.
+     * <h3>API Note</h3>
+     * The task is scheduled on {@link #scheduledExec} even if
+     * {@code delaySeconds == 0} to avoid blocking gRPC worker
+     * thread,
+     * where the {@link BatchContext#onEvent} callback runs.
      *
-     * @apiNote The task is scheduled on {@link #scheduledExec} even if
-     *          {@code delaySeconds == 0} to avoid blocking gRPC worker thread,
-     *          where the {@link BatchContext#onEvent} callback runs.
+     * @param delaySeconds Delay in seconds.
      */
     private void reconnectAfter(long delaySeconds) {
       retries++;

src/main/java/io/weaviate/client6/v1/api/collections/batch/MessageSizeUtil.java

@@ -13,7 +13,8 @@ final class MessageSizeUtil {
    * Safety margin of 1KB to allow for the overhead of surrounding Data field tags
    * and the encoded length of the final payload.
    *
-   * @apiNote Package-private for testing.
+   * <p>
+   * Package-private for testing.
    */
   static final int SAFETY_MARGIN = 1024;
 

src/main/java/io/weaviate/client6/v1/internal/grpc/GrpcTransport.java

@@ -16,9 +16,10 @@ <RequestT, RequestM, ReplyM, ResponseT> CompletableFuture<ResponseT> performRequ
   /**
    * Create stream for batch insertion.
    *
-   * @apiNote Batch insertion is presently the only operation performed over a
-   *          StreamStream connection, which is why we do not parametrize this
-   *          method.
+   * <h3>API Note</h3>
+   * Batch insertion is presently the only operation performed over a
+   * StreamStream connection, which is why we do not parametrize this
+   * method.
    */
   StreamObserver<WeaviateProtoBatch.BatchStreamRequest> createStream(
       StreamObserver<WeaviateProtoBatch.BatchStreamReply> recv);