Apache Flink：如何处理三个流

"我想在一个运算符中接收和处理三个流。例如，Storm中实现的代码如下：

builder.setBolt（“C_bolt”，C_bolt（），parallelism_hint）

            .fieldsGrouping（“A_bolt”，“TRAINING”，新字段（“word”））
            .fieldsGrouping（“B_bolt”，“ANALYSIS”，新字段（“word”））
            .allGrouping（“A_bolt”，“SUM”）;

在Flink中，实现了SUM流（A_bolt的SideOutput）和TRAINING流（A_bolt）的处理：

SingleOutputStreamOperator > A_bolt;
DataStream > Sum = A_bolt.getSideOutput（outputTag）.broadcast（）;
DataStream > B_bolt;
DataStream C_bolt = A_bolt

                    .keyBy（new KeySelector <Tuple3 <String，Integer，Boolean>，String>（）{
                                @覆盖
                                public String getKey（Tuple3 <String，Integer，Boolean> in）抛出异常{
                                    return in.f0;
                                }
                            }）
                    .connect（SUM）
                    .flatMap（new Process（））
                    .setParallelism（平行度）;

但我不知道如何添加ANALYSIS流（B_bolt）。"