Flink中sinkfunction的概念及其实现即richsinkfunction

Question

sinkfunction我正在尝试理解和的概念richsinkfunction。然而，我找不到一个详细解释其底层概念的网站，但我找到的是它的 API 文档。

谁能给我简单解释一下flink中的两个函数sinkfunctionand ？richsinkfunction

Answer 1

流处理管道以接收器结束；接收器消耗流并将其转发到外部系统。例如，它将流写入 Kafka 主题、滚动文件集或数据库等。

Flink 中的所有数据流都以一个或多个源开始，并以一个或多个接收器结束。请参阅文档和培训，以获取更完整的 Flink 概念介绍。

Flink 的用户定义函数有两种风格：简单的和“丰富的”。这些 RichFunction 接口可以连接到 Flink 的更多运行时；特别是，您可以定义open()和close()方法，并使用 Flink 的托管状态机制。丰富的功能就介绍到这里。

大多数重要的接收器都是 RichSinkFunctions，因为它们想要在open()方法中初始化连接并在 中将其拆除close()，但简单的接收器可能不需要这个。