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 defaultBroadcastVariableInitializer
implementation that initializes the broadcast variable into a list.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
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 interfaceBroadcastVariableInitializer<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()
-
-