Package 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<WindowedValue<T>,Map<BoundedWindow,List<T>>,T>

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

All Implemented Interfaces:

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

Enclosing interface:

SideInputValues<T>

public static class SideInputValues.ByWindow<T>
extends SideInputValues.BaseSideInputValues<WindowedValue<T>,Map<BoundedWindow,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

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues

SideInputValues.BaseSideInputValues<BinaryT,ValuesT extends @NonNull Object,T>, SideInputValues.ByWindow<T>, SideInputValues.Global<T>, SideInputValues.Loader<T>

Method Summary

Modifier and Type	Method	Description
List<T>	get(BoundedWindow window)

Methods inherited from class org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues.BaseSideInputValues

read, write

Methods inherited from class java.lang.Object

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

Method Details

get

@Nullable
public List<T> get(BoundedWindow window)