org.apache.flink.runtime.broadcast

Class DefaultBroadcastVariableInitializer<T>

java.lang.Object

org.apache.flink.runtime.broadcast.DefaultBroadcastVariableInitializer<T>

All Implemented Interfaces:

BroadcastVariableInitializer<T,List<T>>

public class DefaultBroadcastVariableInitializer<T>
extends Object
implements BroadcastVariableInitializer<T,List<T>>

The default BroadcastVariableInitializer implementation that initializes the broadcast variable into a list.

Method Summary

Modifier and Type	Method and Description
List<T>	initializeBroadcastVariable(Iterable<T> data) The method that reads the data elements from the broadcast variable and creates the transformed data structure.
static <E> DefaultBroadcastVariableInitializer<E>	instance()

Methods inherited from class java.lang.Object

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

Method Detail

initializeBroadcastVariable

public List<T> initializeBroadcastVariable(Iterable<T> data)

Description copied from interface: BroadcastVariableInitializer

The method that reads the data elements from the broadcast variable and creates the transformed data structure.

The iterable with the data elements can be traversed only once, i.e., only the first call to iterator() will succeed.

Specified by:

initializeBroadcastVariable in interface BroadcastVariableInitializer<T,List<T>>

Parameters:

data - The sequence of elements in the broadcast variable.

Returns:

The transformed broadcast variable.

instance

public static <E> DefaultBroadcastVariableInitializer<E> instance()