我试图理解 sinkfunction 以及 richsinkfunction . 然而，我找不到一个网站详细解释它的基本概念，但我发现它的api文档。谁能简单地解释一下这两个函数 sinkfunction 以及 richsinkfunction 在Flink？
sinkfunction
richsinkfunction
qvtsj1bj1#
流处理管道末端带有Flume；接收器消耗流并将其转发到外部系统。e、 例如，它将流写入Kafka主题、滚动文件集或数据库等。flink中的所有数据流都以一个或多个源开始，以一个或多个接收器结束。有关flink更完整的概念介绍，请参阅文档和培训。flink的用户定义函数有两种风格：简单和“丰富”。这些richfunction接口使我们能够钩住更多的flink运行时；特别是，您可以定义open（）和close（）方法，并使用flink的托管状态机制。丰富的功能在培训和文档中有一点涉及。大多数非常重要的接收器都是richsinkFunction，因为它们希望在open（）方法中初始化连接，并在close（）中将其拆下，但简单的接收器可能不需要这样做。
1条答案
按热度按时间qvtsj1bj1#
流处理管道末端带有Flume；接收器消耗流并将其转发到外部系统。e、 例如，它将流写入Kafka主题、滚动文件集或数据库等。
flink中的所有数据流都以一个或多个源开始，以一个或多个接收器结束。有关flink更完整的概念介绍，请参阅文档和培训。
flink的用户定义函数有两种风格：简单和“丰富”。这些richfunction接口使我们能够钩住更多的flink运行时；特别是，您可以定义open（）和close（）方法，并使用flink的托管状态机制。丰富的功能在培训和文档中有一点涉及。
大多数非常重要的接收器都是richsinkFunction，因为它们希望在open（）方法中初始化连接，并在close（）中将其拆下，但简单的接收器可能不需要这样做。