Remove Beta annotations from MongoDB extension (hazelcast#25743)

JamesHazelcast · Oct 19, 2023 · 53406be · 53406be
1 parent 1ddd0bb
commit 53406be
Show file tree

Hide file tree

Showing 6 changed files with 0 additions and 22 deletions.
diff --git a/extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSinkBuilder.java b/extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSinkBuilder.java
@@ -30,7 +30,6 @@
 import com.hazelcast.jet.pipeline.Sinks;
 import com.hazelcast.jet.retry.RetryStrategies;
 import com.hazelcast.jet.retry.RetryStrategy;
-import com.hazelcast.spi.annotation.Beta;
 import com.mongodb.TransactionOptions;
 import com.mongodb.client.MongoClient;
 import com.mongodb.client.model.ReplaceOptions;
@@ -54,7 +53,6 @@
  *
  * @param <T> type of the items the sink will accept
  */
-@Beta
 @SuppressWarnings({"UnusedReturnValue", "unused"})
 public final class MongoSinkBuilder<T> {
 

diff --git a/extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSinks.java b/extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSinks.java
@@ -19,7 +19,6 @@
 import com.hazelcast.function.SupplierEx;
 import com.hazelcast.jet.pipeline.DataConnectionRef;
 import com.hazelcast.jet.pipeline.Sink;
-import com.hazelcast.spi.annotation.Beta;
 import com.mongodb.client.MongoClient;
 import com.mongodb.client.MongoClients;
 import com.mongodb.client.MongoCollection;
@@ -32,7 +31,6 @@
  *
  * @since 5.3
  */
-@Beta
 public final class MongoSinks {
 
     private MongoSinks() {
@@ -72,7 +70,6 @@ private MongoSinks() {
      * @param itemClass          type of document that will be saved
      * @param <T>                type of the items the sink accepts
      */
-    @Beta
     public static <T> MongoSinkBuilder<T> builder(
             @Nonnull Class<T> itemClass,
             @Nonnull SupplierEx<MongoClient> clientSupplier
@@ -118,7 +115,6 @@ public static <T> MongoSinkBuilder<T> builder(
      * @param <T>               type of the items the sink accepts
      * @since 5.3
      */
-    @Beta
     public static <T> MongoSinkBuilder<T> builder(
             @Nonnull Class<T> itemClass,
             @Nonnull DataConnectionRef dataConnectionRef
@@ -150,7 +146,6 @@ public static <T> MongoSinkBuilder<T> builder(
      * @param database database to which the documents will be put into
      * @param collection collection to which the documents will be put into
      */
-    @Beta
     public static Sink<Document> mongodb(
             @Nonnull String connectionString,
             @Nonnull String database,
@@ -186,7 +181,6 @@ public static Sink<Document> mongodb(
      * @param database database to which the documents will be put into
      * @param collection collection to which the documents will be put into
      */
-    @Beta
     public static Sink<Document> mongodb(
             @Nonnull DataConnectionRef dataConnectionRef,
             @Nonnull String database,

diff --git a/extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSourceBuilder.java b/extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSourceBuilder.java
@@ -27,7 +27,6 @@
 import com.hazelcast.jet.pipeline.DataConnectionRef;
 import com.hazelcast.jet.pipeline.Sources;
 import com.hazelcast.jet.pipeline.StreamSource;
-import com.hazelcast.spi.annotation.Beta;
 import com.mongodb.client.MongoClient;
 import com.mongodb.client.model.Aggregates;
 import com.mongodb.client.model.changestream.ChangeStreamDocument;
@@ -56,7 +55,6 @@
  * @since 5.3
  *
  */
-@Beta
 public final class MongoSourceBuilder {
 
     private MongoSourceBuilder() {

diff --git a/extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSources.java b/extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSources.java
@@ -22,7 +22,6 @@
 import com.hazelcast.jet.pipeline.BatchSource;
 import com.hazelcast.jet.pipeline.DataConnectionRef;
 import com.hazelcast.jet.pipeline.StreamSource;
-import com.hazelcast.spi.annotation.Beta;
 import com.mongodb.client.MongoClient;
 import com.mongodb.client.MongoClients;
 import org.bson.Document;
@@ -65,7 +64,6 @@ private MongoSources() {
      * @param clientSupplier a function that creates MongoDB client.
      * @return Batch Mongo source builder
      */
-    @Beta
     @Nonnull
     public static MongoSourceBuilder.Batch<Document> batch(@Nonnull SupplierEx<? extends MongoClient> clientSupplier) {
         return MongoSourceBuilder.batch(clientSupplier);
@@ -94,7 +92,6 @@ public static MongoSourceBuilder.Batch<Document> batch(@Nonnull SupplierEx<? ext
      * @param dataConnectionRef a reference to mongo data connection
      * @return Batch Mongo source builder
      */
-    @Beta
     @Nonnull
     public static MongoSourceBuilder.Batch<Document> batch(@Nonnull DataConnectionRef dataConnectionRef) {
         return MongoSourceBuilder.batch(dataConnectionRef);
@@ -133,7 +130,6 @@ public static MongoSourceBuilder.Batch<Document> batch(@Nonnull DataConnectionRe
      * @param filter           filter object as a {@link Document}
      * @param projection       projection object as a {@link Document}
      */
-    @Beta
     @Nonnull
     public static BatchSource<Document> batch(
             @Nonnull String connectionString,
@@ -190,7 +186,6 @@ public static BatchSource<Document> batch(
      * @param projection        projection object as a {@link Document}
      * @since 5.3
      */
-    @Beta
     @Nonnull
     public static BatchSource<Document> batch(
             @Nonnull DataConnectionRef dataConnectionRef,
@@ -234,7 +229,6 @@ public static BatchSource<Document> batch(
      * @param clientSupplier a function that creates MongoDB client.
      * @return Stream Mongo source builder
      */
-    @Beta
     @Nonnull
     public static MongoSourceBuilder.Stream<Document> stream(
             @Nonnull SupplierEx<? extends MongoClient> clientSupplier) {
@@ -283,7 +277,6 @@ public static MongoSourceBuilder.Stream<Document> stream(
      * @param filter           filter object as a {@link Document}
      * @param projection       projection object as a {@link Document}
      */
-    @Beta
     @Nonnull
     public static StreamSource<? extends Document> stream(
             @Nonnull String connectionString,

diff --git a/extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/WriteMode.java b/extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/WriteMode.java
@@ -15,14 +15,11 @@
  */
 package com.hazelcast.jet.mongodb;
 
-import com.hazelcast.spi.annotation.Beta;
-
 /**
  * Defines allowed operations.
  *
  * @since 5.3
  */
-@Beta
 public enum WriteMode {
     /**
      * Items will be inserted to MongoDB; in case of ID clash, error will be thrown.

diff --git a/...s/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnection.java b/...s/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnection.java
@@ -20,7 +20,6 @@
 import com.hazelcast.dataconnection.DataConnectionBase;
 import com.hazelcast.dataconnection.DataConnectionResource;
 import com.hazelcast.jet.impl.util.ConcurrentMemoizingSupplier;
-import com.hazelcast.spi.annotation.Beta;
 import com.mongodb.ConnectionString;
 import com.mongodb.MongoClientSettings;
 import com.mongodb.MongoClientSettings.Builder;
@@ -49,7 +48,6 @@
  *
  * @since 5.3
  */
-@Beta
 public class MongoDataConnection extends DataConnectionBase {
 
     /**