Flink扇出 flatMap


0

我使用的是Flink 0.10.0数据流。

    我的源系统是一个广播消息的自定义系统。在我的自定义SourceFunction实现中,我实现了回调来侦听消息。

如何设计具有以下拓扑结构的系统:

来源

我不想把一个的输出发送给另一个。这本质上是一个扇形输出,即我希望它们中的每一个都能并行 job ,也希望源代码能够找出将接收到的消息发送给哪个操作员。

我已经 读取了文档和示例,但找不到与此匹配的示例。非常感谢您的帮助。

1 答案


0

我认为您正在寻找Split操作符,这将在datastreamapi transformation部分的末尾进行 explain。Split操作符将一个输入流导向不同的输出流。


我来回答

写文章

提问题

面试题