GATHER
GATHER собирает записи со всех входящих портов и отправляет в порядке получения на все выходные порты. Порядок получения записей не зависит от порядка входных портов. Этот узел соблюдает порядок записей в потоках, но не соблюдает порядок потоков. На выходе получается список записей в непредсказуемом порядке. Порядок записей на разных выходах будет одинаков. Узел не имеет атрибутов.
Порты GATHER:
| Тип порта | Номер | Обязательный | Описание | Метаданные |
|---|---|---|---|---|
| Input | 0 | да | Для входящего потока записей | Одинаковые метаданные на входных и выходных портах |
| 1-n | нет | Для входящего потока записей | ||
| Output | 0 | да | Для отфильтрованных записей | |
| 1-n | нет | Для отклонённых записей |
Пример. Сбор записей с нескольких входных портов.
Нужно собрать записи с нескольких потоков. Потоки содержат одно поле - "id".
Входящие записи:
Решение:
-
Создать метаданные:
имя="id", тип="integer" -
Поместить компоненты, передающие данные и GATHER на рабочую область.
-
Соединить узлы ребрами и назначить рёбрам метаданные.
-
После запуска графа записи со всех портов будут объединены:
