- 基于flink-1.8.1
概述
- flink 流式计算中需要经计算的结果进行输出(可以是msyql/hbase/ES等常见的DB或者filesystem,也可以是钉钉/邮件/短信等通知类信息),官网上成为connector(连接器)。
-
flink内置的连接器(官网)如下,详情可阅读官网:
flink中SinkFunction类关系
- flink中的的sink connector都是继承的SinkFunction接口;
-
flink-1.8.1中源码类之间的关系展示:
SinkFunction介绍
-
SinkFunction中的方法类
- 从上图中可以看出,flink中自带的 Sink 可以看到都是继承了 RichSinkFunction 抽象类,实现了其中的方法;
- invoke方法中是执行的sink操作;