Apache Flink：为DataStream API添加侧输入

Question

注:Stream-1为主流，Stream-2为侧输入。主流正在不断从Kafka那里获取数据。对于侧输入，最初在应用程序启动时从DB加载所有表数据，然后在表数据更新时读取新数据（不频繁）。

示例结构：

DataStream<Person> stream-1 = env.addSource(read data from kafka)....
DataStream<Address> stream-2 = env.addSource(read data from nifi)....
BroadcastStream<String> BroadCastStream = stream-3.broadcast(read data from kafka);

我被指为以下链接。

用缓慢发展的数据连接流：我们用于丰富的侧输入是随着时间发展的（数据是从DB读取的）。这可以通过等待一些初始数据可用，然后处理主输入，并在新数据到达时不断地将其摄取到内部输入结构中来实现。

Answer 1

根据最新的回应，@Arvid的建议实际上是这里所需要的。

答案的核心：

即使stream1和stream2具有不同的类型，您也可以轻松地将它们连接起来。然后您可以将广播添加到结果中

import org.apache.flink.api.java.functions.KeySelector;
import org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows;
import org.apache.flink.streaming.api.windowing.time.Time;
 
...

DataStream<Integer> orangeStream = ...
DataStream<Integer> greenStream = ...

orangeStream.join(greenStream)
    .where(<KeySelector>)
    .equalTo(<KeySelector>)
    .window(TumblingEventTimeWindows.of(Time.milliseconds(2)))
    .apply (new JoinFunction<Integer, Integer, String> (){
        @Override
        public String join(Integer first, Integer second) {
            return first + "," + second;
        }
    });