Flink扇形flatMap

Question

我使用的是Flink 0.10.0 DataStream。这是我的要求。

• 我的源系统是一个广播消息的自定义系统。在我的自定义SourceFunction实现中，实现了回调以侦听消息。
• 每个回调都得到不同类型的消息。
• 我想对回调中接收的对象进行解码/转换，以发送到我的SinkFunction。这一点我相信我可以用FlatMapFunction或类似的。
• 因为我有不同的回调，所以我听每一个回调的解码逻辑是不同的。我想它们都不可能有一个单独的FlatMapFunction，因为IN类型是不同的。

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

来源

FlatMap_1 (处理回调接收的消息类型1) -> Sink

FlatMap_2 (处理回调接收的消息类型2) -> Sink

FlatMap_3 (处理回调接收到的消息类型) -> Sink

诸若此类。

我不想把一个的输出发送给另一个。这本质上是一个扇出，即，我希望他们中的每一个并行工作，也希望源能够找出谁的运营商发送接收到的消息。

我已经看过文档和示例，但无法找到与此相匹配的示例。希望能在这方面提供帮助。

Answer 1

我想你是在找Split operator，它在DataStream API转换部分末尾已经解释了。分割操作符将一个输入流定向到不同的输出流中。