我想在一个操作符中接收和处理三个流。例如在Storm中实现的代码如下：
builder.setBolt("C_bolt", C_bolt(), parallelism_hint) .fieldsGrouping("A_bolt", "TRAINING", new Fields("word")) .fieldsGrouping("B_bolt", "ANALYSIS", new Fields("word")) .allGrouping("A_bolt", "SUM");
在弗林克，加工SUM stream(A_bolt's SideOutput)和TRAINING stream(A_bolt)实现的：
SingleOutputStreamOperator<Tuple3<String, Integer, Boolean>> A_bolt;
DataStream<Tuple2<Integer, Integer>> Sum = A_bolt.getSideOutput(outputTag).broadcast();
DataStream<Tuple3<String, String, Integer>> B_bolt;
DataStream<String> C_bolt= A_bolt
.keyBy(new KeySelector<Tuple3<String,Integer,Boolean>, String>() {
@Override
public String getKey(Tuple3<String,Integer,Boolean> in) throws Exception {
return in.f0;
}
})
.connect(Sum)
.flatMap(new Process())
.setParallelism(parallelism);
但是不知道怎么加ANALYSIS stream(B_bolt)。感谢您的帮助。
Flink 只支持一输入和二输入的流操作符。您的选择是：
或者这两种技术的组合在您的情况下更可取。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句