каждый N элементов. И при этом из каждого Sink наверх получить materialized value. SubFlow, которые возвращает подходящий свиду оператор splitWhen, - "cannot contribute to the super-flow’s materialized value since they are materialized later, during the runtime of the flow graph processing".
По сути мне надо Source по разным Sink-ам раскидать, которые пишут данные в файлы (и возвращают путь к файлу как materialized value). Чтобы было несколько файлов вместо одного большого.
Броадкаст там был где-то
Обсуждают сегодня