org.apache.beam.runners.fnexecution.control

Class ProcessBundleDescriptors.MultimapSideInputSpec<K,V,W extends BoundedWindow>

java.lang.Object

org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.MultimapSideInputSpec<K,V,W>

Enclosing class:

ProcessBundleDescriptors

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

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

Constructor Summary

Constructors

Constructor and Description
MultimapSideInputSpec()

Method Summary

Modifier and Type	Method and Description
abstract Coder<K>	keyCoder()
abstract java.lang.String	sideInputId()
abstract java.lang.String	transformId()
abstract Coder<V>	valueCoder()
abstract Coder<W>	windowCoder()

Methods inherited from class java.lang.Object

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

Constructor Detail

MultimapSideInputSpec

public MultimapSideInputSpec()

Method Detail

transformId

public abstract java.lang.String transformId()

sideInputId

public abstract java.lang.String sideInputId()

keyCoder

public abstract Coder<K> keyCoder()

valueCoder

public abstract Coder<V> valueCoder()

windowCoder

public abstract Coder<W> windowCoder()