eg.
我有两个DataStream<Tuple4<String, String, Date, String>>，名为 ds1 和 ds2，DataStream ds3 = ds1.union(ds2).然后我想知道如何从 ds3 中获取ds1.f2和ds2.f2的值。
谢谢。
Flink 中的流联合与多集上的联合操作相同——你只是得到一个更大的流，将来自两个输入流的所有元素。
因此，换句话说，联合不是联接。 ds3.f2 是一个值，以前是其中一个流中某个元组的 ds1.f2 或 ds2.f2。
根据您要完成的任务，您可以向每个元组添加第五个元素，以便知道其来源。或者，您可能更愿意使用某种联接操作来组合这两个流。请参阅有关窗口联接、表联接、sql 联接和低级联接的文档。