Слияние (Merge)

Объединяет потоки данных из предыдущих нод в один, по выбранному режиму: просто «склеивает» списки, совмещает по ключам/позициям, строит декартово произведение, выбирает одну ветку, либо выполняет SQL-слияние поверх входов.

Режимы (Mode)

Append / Конкатенация

Выводит все элементы всех входов последовательно. После выбора количества входов (Inputs) нода ждёт данные от всех подключённых входов и собирает данные веток без изменений. Когда нужно объединить результаты двух веток без сопоставления.

Было: [A1, A2] и [B1, B2, B3]

Стало: [A1, A2, B1, B2, B3]

Combine (Комбинация каждого с каждым)

Объединяет пары. Можно использовать когда нужно развернуть матрицу всевозможных вариантов.

Было: цвета [серый, бежевый] и размеры [евро, кинг]

Стало: 4 варианта (серый-евро, серый-кинг, бежевый-евро, бежевый-кинг)

Output Type

• Keep Matches — Оставляет только совпавшие пары по ключам. Два элемента с одинаковыми значениями ключей объединяются в один объект.
• Keep Non-Matches — Оставляет только те элементы, которые не нашли пару ни слева, ни справа. Ничего не объединяется
• Возвращает и совпавшие пары (склеенные), и все, кто не совпал
• Enrich Input 1 — Берёт все элементы из Input 1. Если есть совпадение в Input 2 — добавляет его поля; если нет — возвращает исходник из Input 1 без дополнений.
• Enrich Input 2 — Берёт все элементы из Input 2. Если есть совпадение в Input 1 — добавляет.

Merge by Position (По позиции / индексу)

Сопоставляет по индексу. Элемент с индексом 0 на входе 1 объединяется с элементом с индексом 0 на входе 2 и так далее. Используется когда оба источника вернули списки с одинаковым порядком и длиной.

Было:

• Input 1 → {id: 1, name: "Kate"}, {id: 2, name: "Ira"}
• Input 2 → {city: "Msk"}, {city: "Spb"}

Стало:

• {id:1, name:"Kate", city:"Msk"}, {id:2, name:"Ira", city:"Spb"}

Merge by Key / По ключу (как join в SQL)

Используется, когда нужно свести данные из разных систем по идентификатору.

Ключи: user_id слева и uid справа

Было: пользователи из CRM и заказы из маркетплейса

Стало: к каждому пользователю приклеены его заказы

Choose Branch / Пропустить один поток, подождав второй

Можно исопользовать, когда вторая ветка пишет файл в облако, а надо отправить ссылку из первой, только когда файл точно загружен.

Быстрый выбор режима (шпаргалка)

• Просто сложить списки → Append
• 1-к-1 по порядку → By Position
• Сопоставить по id/sku → By Key
• Дождаться соседнюю ветку, но вернуть мои данные → Pass-through
• Собрать все комбинации → Combine
• Удалить повторы → Remove Duplicates