Flink 操作示例 —— 计算函数 之 ProcessFunction
Posted lemos
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink 操作示例 —— 计算函数 之 ProcessFunction相关的知识，希望对你有一定的参考价值。
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的主要内容，如果未能解决你的问题，请参考以下文章
Flink 系例 之 Connectors 读写 csv 文件