From 494482f03a4eb6031b31ab9d7bf6e0e75c530677 Mon Sep 17 00:00:00 2001 From: Michal Walenia Date: Mon, 20 Apr 2020 08:20:38 +0200 Subject: [PATCH 1/2] [BEAM-9147] Add @Experimental annotation to VideoIntelligence related classes --- .../org/apache/beam/sdk/extensions/ml/AnnotateVideo.java | 2 ++ .../apache/beam/sdk/extensions/ml/VideoIntelligence.java | 6 ++++++ 2 files changed, 8 insertions(+) diff --git a/sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateVideo.java b/sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateVideo.java index 56e863843eea..d74829d36990 100644 --- a/sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateVideo.java +++ b/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 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 extends DoFn> { protected final PCollectionView> contextSideInput; diff --git a/sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/VideoIntelligence.java b/sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/VideoIntelligence.java index 0f447da6498f..9278e542dcb9 100644 --- a/sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/VideoIntelligence.java +++ b/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 @@ * *

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 { 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 { 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> { public AnnotateVideoURIWithContext(List 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> { From b8323c88a24acfdbbfacee57a085f5a18db4aae9 Mon Sep 17 00:00:00 2001 From: Michal Walenia Date: Mon, 20 Apr 2020 11:49:48 +0200 Subject: [PATCH 2/2] Add @Experimental to the package-info as well --- .../java/org/apache/beam/sdk/extensions/ml/package-info.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/package-info.java b/sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/package-info.java index ad5216dd8ccf..241d9028e926 100644 --- a/sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/package-info.java +++ b/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;