org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions

Class SideInputValues.ByWindow<T>

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues.BaseSideInputValues<org.apache.beam.sdk.util.WindowedValue<T>,java.util.Map<BoundedWindow,java.util.List<T>>,T>

org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues.ByWindow<T>

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, java.io.Serializable, SideInputValues<T>

Enclosing interface:

SideInputValues<T>

public static class SideInputValues.ByWindow<T>
extends SideInputValues.BaseSideInputValues<org.apache.beam.sdk.util.WindowedValue<T>,java.util.Map<BoundedWindow,java.util.List<T>>,T>

General SideInputValues for BoundedWindows in two possible states.

Initially it contains the binary values to be broadcasted. On the receiver / executor side the binary values are deserialized once. The binary values are dropped to minimize memory usage.

See Also:

Serialized Form