org.apache.beam.sdk.extensions.ml

Class AnnotateVideo<T>

java.lang.Object

org.apache.beam.sdk.transforms.DoFn<T,java.util.List<com.google.cloud.videointelligence.v1.VideoAnnotationResults>>

org.apache.beam.sdk.extensions.ml.AnnotateVideo<T>

Type Parameters:

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.

All Implemented Interfaces:

java.io.Serializable, HasDisplayData

Direct Known Subclasses:

VideoIntelligence.AnnotateVideoBytesWithContext, VideoIntelligence.AnnotateVideoFromBytes, VideoIntelligence.AnnotateVideoFromURI, VideoIntelligence.AnnotateVideoURIWithContext

@Experimental
public abstract class AnnotateVideo<T>
extends DoFn<T,java.util.List<com.google.cloud.videointelligence.v1.VideoAnnotationResults>>

Base class for Video Intelligence transform.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.DoFn

DoFn.AlwaysFetched, DoFn.BoundedPerElement, DoFn.BundleFinalizer, DoFn.Element, DoFn.FieldAccess, DoFn.FinishBundle, DoFn.FinishBundleContext, DoFn.GetInitialRestriction, DoFn.GetInitialWatermarkEstimatorState, DoFn.GetRestrictionCoder, DoFn.GetSize, DoFn.GetWatermarkEstimatorStateCoder, DoFn.MultiOutputReceiver, DoFn.NewTracker, DoFn.NewWatermarkEstimator, DoFn.OnTimer, DoFn.OnTimerContext, DoFn.OnTimerFamily, DoFn.OnWindowExpiration, DoFn.OutputReceiver<T>, DoFn.ProcessContext, DoFn.ProcessContinuation, DoFn.ProcessElement, DoFn.RequiresStableInput, DoFn.RequiresTimeSortedInput, DoFn.Restriction, DoFn.Setup, DoFn.SideInput, DoFn.SplitRestriction, DoFn.StartBundle, DoFn.StartBundleContext, DoFn.StateId, DoFn.Teardown, DoFn.TimerFamily, DoFn.TimerId, DoFn.Timestamp, DoFn.UnboundedPerElement, DoFn.WatermarkEstimatorState, DoFn.WindowedContext

Field Summary

Fields

Modifier and Type	Field and Description
protected PCollectionView<java.util.Map<T,com.google.cloud.videointelligence.v1.VideoContext>>	contextSideInput
protected java.util.List<com.google.cloud.videointelligence.v1.Feature>	featureList

Constructor Summary

Constructors

Constructor and Description
AnnotateVideo(java.util.List<com.google.cloud.videointelligence.v1.Feature> featureList)
AnnotateVideo(PCollectionView<java.util.Map<T,com.google.cloud.videointelligence.v1.VideoContext>> contextSideInput, java.util.List<com.google.cloud.videointelligence.v1.Feature> featureList)

Method Summary

Modifier and Type	Method and Description
abstract void	processElement(DoFn.ProcessContext context) Process element implementation required.
void	startBundle()
void	teardown()

Methods inherited from class org.apache.beam.sdk.transforms.DoFn

getAllowedTimestampSkew, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData, prepareForProcessing

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

contextSideInput

protected final PCollectionView<java.util.Map<T,com.google.cloud.videointelligence.v1.VideoContext>> contextSideInput

featureList

protected final java.util.List<com.google.cloud.videointelligence.v1.Feature> featureList

Constructor Detail

AnnotateVideo

public AnnotateVideo(PCollectionView<java.util.Map<T,com.google.cloud.videointelligence.v1.VideoContext>> contextSideInput,
                     java.util.List<com.google.cloud.videointelligence.v1.Feature> featureList)

AnnotateVideo

public AnnotateVideo(java.util.List<com.google.cloud.videointelligence.v1.Feature> featureList)

Method Detail

startBundle

@DoFn.StartBundle
public void startBundle()
                                   throws java.io.IOException

Throws:

java.io.IOException

teardown

@DoFn.Teardown
public void teardown()

processElement

@DoFn.ProcessElement
public abstract void processElement(DoFn.ProcessContext context)
                                                  throws java.util.concurrent.ExecutionException,
                                                         java.lang.InterruptedException

Process element implementation required.

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException