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.

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