Flink流是不变的吗?

Question

我需要使用Flink分开数据流。

名为" myds"的第一个 - 包含重复的数据

名为" GoodDataStream"的第二个应过滤重复

部分代码是：

goodDataStream = myDs
             .filter( new DedupeFilterFunction())  // does this line affects myDs also?

// createSync for goodDataStream

// createSync for myDs

我的问题是：

是否意味着MyDS同步还包括新的DedupeFilterFunction（）

谢谢。

Answer 1

DataStream是不可变的。因此，在您的情况下，myDs不会应用DedupeFilterFunction。