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 org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor	getProcessBundleDescriptor()
abstract java.util.List<RemoteInputDestination>	getRemoteInputDestinations() Get RemoteInputDestinations that input data are sent to the BeamFnApi.ProcessBundleDescriptor over.
abstract java.util.Map<java.lang.String,Coder>	getRemoteOutputCoders() Get all of the transforms materialized by this ProcessBundleDescriptors.ExecutableProcessBundleDescriptor and the Java Coder for the wire format of that transform.
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.List<RemoteInputDestination> inputDestinations, java.util.Map<java.lang.String,Coder> outputTransformCoders, 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.List<RemoteInputDestination> inputDestinations,
                                                                            java.util.Map<java.lang.String,Coder> outputTransformCoders,
                                                                            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.List<RemoteInputDestination> getRemoteInputDestinations()

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

getRemoteOutputCoders

public abstract java.util.Map<java.lang.String,Coder> getRemoteOutputCoders()

Get all of the transforms materialized by this ProcessBundleDescriptors.ExecutableProcessBundleDescriptor and the Java Coder for the wire format of that transform.

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.