Class ProcessBundleDescriptors.SideInputSpec<T,W extends BoundedWindow>
java.lang.Object
org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.SideInputSpec<T,W>
- Enclosing class:
ProcessBundleDescriptors
public abstract static class ProcessBundleDescriptors.SideInputSpec<T,W extends BoundedWindow>
extends Object
A container type storing references to the value, and window
Coder
used when handling
side input state requests.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionabstract org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec
static <T,
W extends BoundedWindow>
ProcessBundleDescriptors.SideInputSpecof
(String transformId, String sideInputId, org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec accessPattern, Coder<T> elementCoder, Coder<W> windowCoder) abstract String
abstract String
-
Constructor Details
-
SideInputSpec
public SideInputSpec()
-
-
Method Details
-
of
public static <T,W extends BoundedWindow> ProcessBundleDescriptors.SideInputSpec of(String transformId, String sideInputId, org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec accessPattern, Coder<T> elementCoder, Coder<W> windowCoder) -
transformId
-
sideInputId
-
accessPattern
public abstract org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec accessPattern() -
elementCoder
-
windowCoder
-