public abstract static class ProcessBundleDescriptors.ExecutableProcessBundleDescriptor
extends java.lang.Object
Constructor and Description |
---|
ExecutableProcessBundleDescriptor() |
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 RemoteInputDestination<org.apache.beam.sdk.util.WindowedValue<?>> |
getRemoteInputDestination()
Get the
RemoteInputDestination that input data 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. |
static ProcessBundleDescriptors.ExecutableProcessBundleDescriptor |
of(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor descriptor,
RemoteInputDestination<org.apache.beam.sdk.util.WindowedValue<?>> inputDestination,
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) |
public static ProcessBundleDescriptors.ExecutableProcessBundleDescriptor of(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor descriptor, RemoteInputDestination<org.apache.beam.sdk.util.WindowedValue<?>> inputDestination, 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)
public abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleDescriptor getProcessBundleDescriptor()
public abstract RemoteInputDestination<org.apache.beam.sdk.util.WindowedValue<?>> getRemoteInputDestination()
RemoteInputDestination
that input data are sent to the BeamFnApi.ProcessBundleDescriptor
over.public abstract java.util.Map<org.apache.beam.model.fnexecution.v1.BeamFnApi.Target,Coder<org.apache.beam.sdk.util.WindowedValue<?>>> getOutputTargetCoders()
ProcessBundleDescriptors.ExecutableProcessBundleDescriptor
and the
java Coder
for the wire format of that BeamFnApi.Target
.public abstract java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.SideInputSpec>> getSideInputSpecs()
side inputs
that
are used during execution.public abstract java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.BagUserStateSpec>> getBagUserStateSpecs()
bag user
states
that are used during execution.