flink的sink

sink作用:

flink三大逻辑结构之一(source,transform,sink),功能就是负责把flink处理后的数据输出到外部系统中,flink 的sink和source的代码结构类似

首先看下sink的类继承图如下:

核心类:

SinkFunction 是一个接口,类似于SourceFunction接口。SinkFunction中主要包含一个方法,那就是用于数据输出的invoke 方法,每条记录都会执行一次invoke方法,用于执行输出操作

AbstractRichFunction这个抽象类实现了RichFunction接口,并且提供了关于RuntimContext的操作和open,clone方法

AbstractRichFunction 有很多实现类,如:关于msyql操作的JDBCSinkFunction、直接输出结果的 PrintSinkFunction

自定义Sink的时候,都是继承AbstractRichFunction

......

原文地址:https://www.cnblogs.com/zyanrong/p/15126949.html