Flink 1.17教程：输出算子（Sink）之连接到外部系统

Love The Way You Lie 2023-10-15 18:20 5阅读 0赞

## 输出算子（Sink） ##

Flink作为数据处理框架，最终还是要把计算处理的结果写入外部存储，为外部应用提供支持。  
![在这里插入图片描述][8115ec8c6d1b41259aa325f71e352997.png]

### 连接到外部系统 ###

Flink的DataStream API专门提供了向外部写入数据的方法：addSink。与addSource类似，addSink方法对应着一个“Sink”算子，主要就是用来实现与外部系统连接、并将数据提交写入的；Flink程序中所有对外的输出操作，一般都是利用Sink算子完成的。  
Flink1.12以前，Sink算子的创建是通过调用DataStream的.addSink()方法实现的。

stream.addSink(new SinkFunction(…));

addSink方法同样需要传入一个参数，实现的是SinkFunction接口。在这个接口中只需要重写一个方法invoke()，用来将指定的值写入到外部系统中。这个方法在每条数据记录到来时都会调用。  
Flink1.12开始，同样重构了Sink架构，

stream.sinkTo(…)

当然，Sink多数情况下同样并不需要我们自己实现。之前我们一直在使用的print方法其实就是一种Sink，它表示将数据流写入标准控制台打印输出。Flink官方为我们提供了一部分的框架的Sink连接器。如下图所示，列出了Flink官方目前支持的第三方系统连接器：  
![在这里插入图片描述][cd861c0f4c2646d2ae3bd395edb129d0.png]

我们可以看到，像Kafka之类流式系统，Flink提供了完美对接，source/sink两端都能连接，可读可写；而对于Elasticsearch、JDBC等数据存储系统，则只提供了输出写入的sink连接器。  
除Flink官方之外，Apache Bahir框架，也实现了一些其他第三方系统与Flink的连接器。  
![在这里插入图片描述][6b1bfe03b9f649d28d08b8c3f4327a16.png]

除此以外，就需要用户自定义实现sink连接器了。

[8115ec8c6d1b41259aa325f71e352997.png]: https://img-blog.csdnimg.cn/8115ec8c6d1b41259aa325f71e352997.png
[cd861c0f4c2646d2ae3bd395edb129d0.png]: https://img-blog.csdnimg.cn/cd861c0f4c2646d2ae3bd395edb129d0.png
[6b1bfe03b9f649d28d08b8c3f4327a16.png]: https://img-blog.csdnimg.cn/6b1bfe03b9f649d28d08b8c3f4327a16.png