0
点赞
收藏
分享

微信扫一扫

Flink SourceFunction 初了解

夏木之下 2022-03-11 阅读 61
Flink

1. SourceFunction

在这里插入图片描述

SourceFunction 是 Flink 中所有流数据 Source 的基本接口。SourceFunction 接口继承了 Function 接口,并在内部定义了数据读取使用的 run() 方法、取消运行的 cancel() 方法以及 SourceContext 内部接口:

public interface SourceFunction<T> extends Function, Serializable {
   
    
举报

相关推荐

0 条评论