This is an automated email from the ASF dual-hosted git repository.
ahmedabualsaud pushed a commit to branch release-2.58.0
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/release-2.58.0 by this push:
new 6e6f28027bc add doc warning against using icebergio directly (#31834)
6e6f28027bc is described below
commit 6e6f28027bcd875733f20ee1be303815d0227eb7
Author: Ahmed Abualsaud <[email protected]>
AuthorDate: Wed Jul 10 14:33:25 2024 -0400
add doc warning against using icebergio directly (#31834)
---
.../src/main/java/org/apache/beam/sdk/io/iceberg/IcebergIO.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git
a/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergIO.java
b/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergIO.java
index 75a35e6f8a3..50e0ea8b63d 100644
---
a/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergIO.java
+++
b/sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergIO.java
@@ -22,6 +22,7 @@ import static
org.apache.beam.sdk.util.Preconditions.checkStateNotNull;
import com.google.auto.value.AutoValue;
import java.util.Arrays;
import java.util.List;
+import org.apache.beam.sdk.annotations.Internal;
import org.apache.beam.sdk.io.Read;
import org.apache.beam.sdk.transforms.PTransform;
import org.apache.beam.sdk.values.PBegin;
@@ -33,6 +34,13 @@ import org.apache.iceberg.Table;
import org.apache.iceberg.catalog.TableIdentifier;
import org.checkerframework.checker.nullness.qual.Nullable;
+/**
+ * The underlying Iceberg connector used by {@link
org.apache.beam.sdk.managed.Managed#ICEBERG}. Not
+ * intended to be used directly.
+ *
+ * <p>For internal use only; no backwards compatibility guarantees
+ */
+@Internal
public class IcebergIO {
public static WriteRows writeRows(IcebergCatalogConfig catalog) {
