我有两个 DataStream 如下所示：

DataStream<String> dataA = env.addSource(sourceA);
DataStream<String> dataB = env.addSource(sourceB);

我需要的是处理 dataB 有条件地根据 dataA .
说sourcea正在发送： a, b, a, b, a, a, b, a, b, b... . 我需要的东西如下：

DataStream<String> res = dataB.map(new MapFUnction<String, String>() {
    @Override
    public String map(String s) throws Exception {
        if (currentValueOfA == "a") {
            processDataBWithMethodA();
        } else {
            processDataBWithMethodB();
        }
    }
});

总之， dataA 是一种控制流，它控制如何处理 dataB .
我试过阅读flink的文档，似乎我需要一些广播机制，但是我找不到一个简单的例子来帮助我理解如何使用这个机制。
你能告诉我怎么广播吗 dataA 至 dataB ?