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

Class SideInputValues.Global<T>

java.lang.Object

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

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

All Implemented Interfaces:

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

Enclosing interface:

SideInputValues<T>

public static class SideInputValues.Global<T>
extends SideInputValues.BaseSideInputValues<T,java.util.List<T>,T>

Specialized SideInputValues for use with the GlobalWindow 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