Flink扇出平面地图

Question

我使用的是Flink 0.10.0数据流。这是我的要求。

• 我的源系统是广播消息的自定义系统。在我的自定义SourceFunction实现中，我实现了回调来侦听消息。
• 每个回调都会得到不同类型的消息。
• 我想解码/转换在回调中收到的对象发送到我的SinkFunction。我相信我可以用FlatMapFunction或类似的软件来完成。
• 因为我有各种回调，所以我听每个回调的解码逻辑是不同的。我想不能有一个单一的FlatMapFunction为他们所有的IN类型将是不同的。

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

Source
|-FlatMap_1（处理回调1收到的消息类型）-

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

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

Answer 1

我认为您正在寻找Split运算符，这在DataStream API转换部分的末尾进行了解释。Split运算符将一个输入流引导到不同的输出流。