Package org.apache.beam.runners.flink.translation.functions

Class SideInputInitializer<ViewT>

java.lang.Object

org.apache.beam.runners.flink.translation.functions.SideInputInitializer<ViewT>

All Implemented Interfaces:

org.apache.flink.api.common.functions.BroadcastVariableInitializer<WindowedValue<?>,Map<BoundedWindow,ViewT>>

public class SideInputInitializer<ViewT>
extends Object
implements org.apache.flink.api.common.functions.BroadcastVariableInitializer<WindowedValue<?>,Map<BoundedWindow,ViewT>>

BroadcastVariableInitializer that initializes the broadcast input as a Map from window to side input.

Constructor Summary

Constructors

Constructor	Description
SideInputInitializer(PCollectionView<ViewT> view)

Method Summary

Modifier and Type	Method	Description
Map<BoundedWindow,ViewT>	initializeBroadcastVariable(Iterable<WindowedValue<?>> inputValues)

Methods inherited from class java.lang.Object

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

Constructor Details

SideInputInitializer

public SideInputInitializer(PCollectionView<ViewT> view)

Method Details

initializeBroadcastVariable

public Map<BoundedWindow,ViewT> initializeBroadcastVariable(Iterable<WindowedValue<?>> inputValues)

Specified by:

initializeBroadcastVariable in interface org.apache.flink.api.common.functions.BroadcastVariableInitializer<WindowedValue<?>,Map<BoundedWindow,ViewT>>