标签：cal UNC scala cep out 示例 sele open parameter
RichFunction
主要有3个方法 open，close，getRuntimeContext
public interface RichFunction extends Function {
void open(Configuration parameters) throws Exception;
void close() throws Exception;
RuntimeContext getRuntimeContext();
...
}
KeyedProcessFunction
主要有 2 个方法, processElement，onTimer
public abstract class KeyedProcessFunction<K, I, O> extends AbstractRichFunction {
public abstract void processElement(I value, Context ctx, Collector<O> out) throws Exception;
public void onTimer(long timestamp, OnTimerContext ctx, Collector<O> out) throws Exception {
}
...
}
233
Flink 操作示例 —— 计算函数 之 ProcessFunction
标签：cal UNC scala cep out 示例 sele open parameter
原文地址：https://www.cnblogs.com/lemos/p/13061473.html
