org.apache.samza.operators.functions

Interface InitableFunction

All Known Subinterfaces:

FilterFunction<M>, FlatMapFunction<M,OM>, FoldLeftFunction<M,WV>, InputTransformer<OM>, JoinFunction<K,M,JM,RM>, MapFunction<M,OM>, SinkFunction<M>, StreamTableJoinFunction<K,M,R,JM>, SupplierFunction<T>

@InterfaceStability.Evolving
public interface InitableFunction

A function that can be initialized before execution.

Order of initialization: InitableFunctions are invoked in the topological order of operators in the StreamApplicationDescriptor. For any two operators A and B in the graph, if operator B consumes results from operator A, then operator A is guaranteed to be initialized before operator B.

Method Summary

Modifier and Type	Method and Description
default void	init(Context context) Initializes the function before any messages are processed.

Method Detail

init

default void init(Context context)

Initializes the function before any messages are processed.

Parameters:

context - the Context for this task