bro,how to do this...somebody help🙏

What's the source of temp_result_data? If it's an external source, then you can connect the temp_result_data and raw_data streams and process the "connected" stream via `CoProcessFunction`s, e.g.

raw_data_stream.connect(temp_result_data_stream).process(new Operator2CoProcessFunction())

. You may need to consider assigning keys to each stream before connecting them and process with

KeyedCoProcessFunction

. If internal, ie output from another operator, it should be a

DataStream

already so you can just connect them the same as described above.