CONCATENATE
CONCATENATE получает записи, поступившие из первого входного порта, отправляет их на общий выходной порт и добавляет к ним записи, из остальных входных портов. Если шаг имеет более двух входных портов, записи принимаются и отправляются на выход в соответствии с порядком входных портов. Если некоторые входные порты не содержат записей, такие порты пропускаются. Шаг не имеет атрибутов.
Тип порта | Номер | Обязательный | Описание | Метаданные |
---|---|---|---|---|
Input | 0 | да | Для входящего потока записей | Любые |
1-n | нет | Как у Input 0 | ||
Output | 0 | да | Для объединенных записей |
Пример. Объединение записей.
Нужно объединить записи. Поданные на вход метаданные имеют поля «flower», «color».
Входящие записи:
порт 0:
flower | color |
---|---|
мак | красный |
ромашка | белый |
василек | голубой |
порт 1:
flower | color |
---|---|
роза | сиреневый |
лилия | розовый |
порт 2:
flower | color |
---|---|
подсолнух | желтый |
анемон | вишневый |
гипсофила | зеленый |
Решение:
После конкатенации будут получены следующие записи.
Исходящие записи:
порт 0:
flower | color |
---|---|
мак | красный |
ромашка | белый |
василек | голубой |
роза | сиреневый |
лилия | розовый |
подсолнух | желтый |
анемон | вишневый |
гипсофила | зеленый |