確實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。