This is an automated email from the ASF dual-hosted git repository.
ahmedabualsaud pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new dd0912460c4 add doc warning against using icebergio directly (#31833)
dd0912460c4 is described below
commit dd0912460c4e106cc27ef4547d00ace07235431e
Author: Ahmed Abualsaud <[email protected]>
AuthorDate: Wed Jul 10 14:01:39 2024 -0400
add doc warning against using icebergio directly (#31833)
---
.../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) {
