Вы уверены, что хотите добавить слияние, а не фиктивные или добавленные потоки для добавления строк?
Строки слияния фактически выполнят объединение.Если у вас много попаданий, когда ключи одного потока совпадают с ключами другого (или, что еще хуже, если у вас нет ключей, что приводит к перекрестному соединению), вы будете создавать кошмар с точки зрения количества элементов.
Что еще хуже, объединение слиянием не сможет завершиться, пока есть входные строки, поступающие из любого потока данных из строк фильтра, сохраняя огромный набор данных в памяти.
Если объединение действительно то, что вам нужно, вы должны тщательно проанализировать мощность набора результатов, но также добавить два шага Сортировать строки перед объединением слиянием, которое должно отсортировать каждый поток по ключам объединения, а также имеетВыгодно от разъединения потока данных, что позволяет объединению слиянием запускать весь поток за один раз, не вызывая потенциальных тупиков в вашем преобразовании.