org.apache.beam.runners.fnexecution.control

Class ProcessBundleDescriptors.SideInputSpec<K,T,W extends BoundedWindow>

java.lang.Object

org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.SideInputSpec<K,T,W>

Enclosing class:

ProcessBundleDescriptors

public abstract static class ProcessBundleDescriptors.SideInputSpec<K,T,W extends BoundedWindow>
extends java.lang.Object

A container type storing references to the key, value, and window Coder used when handling side input state requests.

Constructor Summary

Constructors

Constructor and Description
SideInputSpec()

Method Summary

Modifier and Type	Method and Description
abstract org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec	accessPattern()
abstract Coder<T>	elementCoder()
static <T,W extends BoundedWindow> ProcessBundleDescriptors.SideInputSpec	of(java.lang.String transformId, java.lang.String sideInputId, org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec accessPattern, Coder<T> elementCoder, Coder<W> windowCoder)
abstract java.lang.String	sideInputId()
abstract java.lang.String	transformId()
abstract Coder<W>	windowCoder()

Methods inherited from class java.lang.Object

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

Constructor Detail

SideInputSpec

public SideInputSpec()

Method Detail

of

public static <T,W extends BoundedWindow> ProcessBundleDescriptors.SideInputSpec of(java.lang.String transformId,
                                                                                    java.lang.String sideInputId,
                                                                                    org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec accessPattern,
                                                                                    Coder<T> elementCoder,
                                                                                    Coder<W> windowCoder)

transformId

public abstract java.lang.String transformId()

sideInputId

public abstract java.lang.String sideInputId()

accessPattern

public abstract org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec accessPattern()

elementCoder

public abstract Coder<T> elementCoder()

windowCoder

public abstract Coder<W> windowCoder()