我试图理解 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()中将其拆下,但简单的接收器可能不需要这样做。