org.apache.beam.runners.fnexecution.control

Class ProcessBundleDescriptors.ExecutableProcessBundleDescriptor

java.lang.Object

org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.ExecutableProcessBundleDescriptor

Enclosing class:

ProcessBundleDescriptors

public abstract static class ProcessBundleDescriptors.ExecutableProcessBundleDescriptor
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ExecutableProcessBundleDescriptor()

Method Summary

Modifier and Type	Method and Description
abstract java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.BagUserStateSpec>>	getBagUserStateSpecs() Get a mapping from PTransform id to user state input id to bag user states that are used during execution.
abstract java.util.Map<org.apache.beam.model.fnexecution.v1.BeamFnApi.Target,Coder<org.apache.beam.sdk.util.WindowedValue<?>>>	getOutputTargetCoders() Get all of the targets materialized by this ProcessBundleDescriptors.ExecutableProcessBundleDescriptor and the java Coder for the wire format of that BeamFnApi.Target.
abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor	getProcessBundleDescriptor()
abstract java.util.Map<java.lang.String,RemoteInputDestination<org.apache.beam.sdk.util.WindowedValue<?>>>	getRemoteInputDestinations() Get RemoteInputDestinations that input data/timers are sent to the BeamFnApi.ProcessBundleDescriptor over.
abstract java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.SideInputSpec>>	getSideInputSpecs() Get a mapping from PTransform id to side input id to side inputs that are used during execution.
abstract java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.TimerSpec>>	getTimerSpecs() Get a mapping from PTransform id to timer id to timer specs that are used during execution.
static ProcessBundleDescriptors.ExecutableProcessBundleDescriptor	of(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor descriptor, java.util.Map<java.lang.String,RemoteInputDestination<org.apache.beam.sdk.util.WindowedValue<?>>> inputDestinations, java.util.Map<org.apache.beam.model.fnexecution.v1.BeamFnApi.Target,Coder<org.apache.beam.sdk.util.WindowedValue<?>>> outputTargetCoders, java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.SideInputSpec>> sideInputSpecs, java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.BagUserStateSpec>> bagUserStateSpecs, java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.TimerSpec>> timerSpecs)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutableProcessBundleDescriptor

public ExecutableProcessBundleDescriptor()

Method Detail

of

public static ProcessBundleDescriptors.ExecutableProcessBundleDescriptor of(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor descriptor,
                                                                            java.util.Map<java.lang.String,RemoteInputDestination<org.apache.beam.sdk.util.WindowedValue<?>>> inputDestinations,
                                                                            java.util.Map<org.apache.beam.model.fnexecution.v1.BeamFnApi.Target,Coder<org.apache.beam.sdk.util.WindowedValue<?>>> outputTargetCoders,
                                                                            java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.SideInputSpec>> sideInputSpecs,
                                                                            java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.BagUserStateSpec>> bagUserStateSpecs,
                                                                            java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.TimerSpec>> timerSpecs)

getProcessBundleDescriptor

public abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor getProcessBundleDescriptor()

getRemoteInputDestinations

public abstract java.util.Map<java.lang.String,RemoteInputDestination<org.apache.beam.sdk.util.WindowedValue<?>>> getRemoteInputDestinations()

Get RemoteInputDestinations that input data/timers are sent to the BeamFnApi.ProcessBundleDescriptor over.

getOutputTargetCoders

public abstract java.util.Map<org.apache.beam.model.fnexecution.v1.BeamFnApi.Target,Coder<org.apache.beam.sdk.util.WindowedValue<?>>> getOutputTargetCoders()

Get all of the targets materialized by this ProcessBundleDescriptors.ExecutableProcessBundleDescriptor and the java Coder for the wire format of that BeamFnApi.Target.

getSideInputSpecs

public abstract java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.SideInputSpec>> getSideInputSpecs()

Get a mapping from PTransform id to side input id to side inputs that are used during execution.

getBagUserStateSpecs

public abstract java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.BagUserStateSpec>> getBagUserStateSpecs()

Get a mapping from PTransform id to user state input id to bag user states that are used during execution.

getTimerSpecs

public abstract java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.TimerSpec>> getTimerSpecs()

Get a mapping from PTransform id to timer id to timer specs that are used during execution.