org.apache.samza.operators.functions

Interface InitableFunction

All Known Subinterfaces:

FilterFunction<M>, FlatMapFunction<M,OM>, FoldLeftFunction<M,WV>, JoinFunction<K,M,JM,RM>, MapFunction<M,OM>, SinkFunction<M>

@InterfaceStability.Unstable
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 StreamGraph. 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(Config config, TaskContext context) Initializes the function before any messages are processed.

Method Detail

init

default void init(Config config,
                  TaskContext context)

Initializes the function before any messages are processed.

Parameters:

config - the Config for the application

context - the TaskContext for this task