如。我有两个 DataStream<Tuple4<String, String, Date, String>> 命名为ds1和ds2， DataStream ds3 = ds1.union(ds2) 那么我想知道怎样才能得到 ds1.f2 以及 ds2.f2 来自ds3。谢谢。
DataStream<Tuple4<String, String, Date, String>>
DataStream ds3 = ds1.union(ds2)
ds1.f2
ds2.f2
tp5buhyn1#
flink中的流联合与multisets上的联合操作相同——您只需获得一个更大的流，就可以从两个输入流中获得所有元素。所以，换言之，联合不是联合。对于其中一个流中的某个元组，ds3.f2是以前为ds1.f2或ds2.f2的值。根据您要完成的任务，您可以向每个元组添加第五个元素，以便知道它的起源。或者您可以使用某种连接操作来组合这两个流。请参阅有关窗口联接、表联接、sql联接和低级联接的文档。
1条答案
按热度按时间tp5buhyn1#
flink中的流联合与multisets上的联合操作相同——您只需获得一个更大的流，就可以从两个输入流中获得所有元素。
所以，换言之，联合不是联合。对于其中一个流中的某个元组，ds3.f2是以前为ds1.f2或ds2.f2的值。
根据您要完成的任务，您可以向每个元组添加第五个元素，以便知道它的起源。或者您可以使用某种连接操作来组合这两个流。请参阅有关窗口联接、表联接、sql联接和低级联接的文档。