Merge pull request apache#11463 from apache/BEAM-9147-add-experimenta…

…l-annotation

[BEAM-9147] Add @experimental annotation to VideoIntelligence related classes

sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateVideo.java

@@ -30,6 +30,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ExecutionException;
+import org.apache.beam.sdk.annotations.Experimental;
 import org.apache.beam.sdk.transforms.DoFn;
 import org.apache.beam.sdk.values.PCollectionView;
 
@@ -39,6 +40,7 @@
  * @param <T> Class of input data being passed in - either ByteString - video data encoded into.
  * String or String - a GCS URI of the video to be annotated.
  */
+@Experimental
 public abstract class AnnotateVideo<T> extends DoFn<T, List<VideoAnnotationResults>> {
 
  protected final PCollectionView<Map<T, VideoContext>> contextSideInput;

sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/VideoIntelligence.java

@@ -24,6 +24,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ExecutionException;
+import org.apache.beam.sdk.annotations.Experimental;
 import org.apache.beam.sdk.values.KV;
 import org.apache.beam.sdk.values.PCollectionView;
 
@@ -37,6 +38,7 @@
  *
  * <p>Service account with proper permissions is required to use these transforms.
  */
+@Experimental
 public class VideoIntelligence {
 
  /**
@@ -88,6 +90,7 @@ public static AnnotateVideoBytesWithContext annotateFromBytesWithContext(
  * Implementation of AnnotateVideo accepting Strings as contents of input PCollection. Annotates
  * videos found on GCS based on URIs from input PCollection.
  */
+ @Experimental
  public static class AnnotateVideoFromURI extends AnnotateVideo<String> {
 
  public AnnotateVideoFromURI(
@@ -114,6 +117,7 @@ public void processElement(ProcessContext context)
  * Implementation of AnnotateVideo accepting ByteStrings as contents of input PCollection. Videos
  * decoded from the ByteStrings are annotated.
  */
+ @Experimental
  public static class AnnotateVideoFromBytes extends AnnotateVideo<ByteString> {
 
  public AnnotateVideoFromBytes(
@@ -141,6 +145,7 @@ public void processElement(ProcessContext context)
  * Implementation of AnnotateVideo accepting KVs as contents of input PCollection. Keys are the
  * GCS URIs, values - VideoContext objects.
  */
+ @Experimental
  public static class AnnotateVideoURIWithContext extends AnnotateVideo<KV<String, VideoContext>> {
 
  public AnnotateVideoURIWithContext(List<Feature> featureList) {
@@ -163,6 +168,7 @@ public void processElement(ProcessContext context)
  * Implementation of AnnotateVideo accepting KVs as contents of input PCollection. Keys are the
  * ByteString encoded video contents, values - VideoContext objects.
  */
+ @Experimental
  public static class AnnotateVideoBytesWithContext
  extends AnnotateVideo<KV<ByteString, VideoContext>> {
 

sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/package-info.java

@@ -16,4 +16,7 @@
  * limitations under the License.
  */
 /** Provides DoFns for integration with Google Cloud AI Video Intelligence service. */
+@Experimental
 package org.apache.beam.sdk.extensions.ml;
+
+import org.apache.beam.sdk.annotations.Experimental;