Package org.apache.beam.runners.fnexecution.control

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

Constructor	Description
SideInputSpec()

Method Summary

Modifier and Type	Method	Description
abstract org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec	accessPattern()
abstract Coder<T>	elementCoder()
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)
abstract String	sideInputId()
abstract 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 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

public abstract String transformId()

sideInputId

public abstract 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()