является ли поток flink неизменным?

Мне нужно разделить поток данных с помощью flink.

первый с именем "myDs" - содержит повторяющиеся данные

второй, названный "goodDataStream", должен фильтровать дубликаты.

частичный код:

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


// createSync for goodDataStream


// createSync for myDs

мой вопрос:

означает ли это, что синхронизация myDs также включает новую функцию DedupeFilterFunction ()

Спасибо.


apache-flink flink-streaming
person roman    schedule 16.03.2017    source источник

Ответы (1)


arrow_upward
2
arrow_downward

DataStream неизменен. Таким образом, в вашем случае myDs не будет применяться DedupeFilterFunction.

person Dawid Wysakowicz    schedule 16.03.2017