Package 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 Object

Constructor Summary

Constructors

Constructor	Description
ExecutableProcessBundleDescriptor()

Method Summary

Modifier and Type	Method	Description
abstract Map<String,Map<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 List<RemoteInputDestination>	getRemoteInputDestinations()	Get RemoteInputDestinations that input data are sent to the BeamFnApi.ProcessBundleDescriptor over.
abstract Map<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 Map<String,Map<String,ProcessBundleDescriptors.SideInputSpec>>	getSideInputSpecs()	Get a mapping from PTransform id to side input id to side inputs that are used during execution.
abstract Map<String,Map<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, List<RemoteInputDestination> inputDestinations, Map<String,Coder> outputTransformCoders, Map<String,Map<String,ProcessBundleDescriptors.SideInputSpec>> sideInputSpecs, Map<String,Map<String,ProcessBundleDescriptors.BagUserStateSpec>> bagUserStateSpecs, Map<String,Map<String,ProcessBundleDescriptors.TimerSpec>> timerSpecs)

Methods inherited from class java.lang.Object

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

Constructor Details

ExecutableProcessBundleDescriptor

public ExecutableProcessBundleDescriptor()

Method Details

of

public static ProcessBundleDescriptors.ExecutableProcessBundleDescriptor of(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor descriptor,
 List<RemoteInputDestination> inputDestinations,
 Map<String,Coder> outputTransformCoders,
 Map<String,Map<String,ProcessBundleDescriptors.SideInputSpec>> sideInputSpecs,
 Map<String,Map<String,ProcessBundleDescriptors.BagUserStateSpec>> bagUserStateSpecs,
 Map<String,Map<String,ProcessBundleDescriptors.TimerSpec>> timerSpecs)

getProcessBundleDescriptor

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

getRemoteInputDestinations

public abstract List<RemoteInputDestination> getRemoteInputDestinations()

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

getRemoteOutputCoders

public abstract Map<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 Map<String,Map<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 Map<String,Map<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 Map<String,Map<String,ProcessBundleDescriptors.TimerSpec>> getTimerSpecs()

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