Flink SourceFunction 初了解
Posted @SmartSi
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink SourceFunction 初了解相关的知识，希望对你有一定的参考价值。
1. SourceFunction
SourceFunction 是 Flink 中所有流数据 Source 的基本接口。SourceFunction 接口继承了 Function 接口，并在内部定义了数据读取使用的 run() 方法、取消运行的 cancel() 方法以及 SourceContext 内部接口：
public interface SourceFunction<T> extends Function, Serializable
以上是关于Flink SourceFunction 初了解的主要内容，如果未能解决你的问题，请参考以下文章