• 周四. 4月 25th, 2024

5G编程聚合网

5G时代下一个聚合的编程学习网

热门标签

flink的sink

admin

11月 28, 2021

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

……

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注