SIMPLE_COPY
SIMPLE_COPY получает записи через один входной порт и копирует каждую из них на все подключенные выходные порты. Шаг не имеет атрибутов.
Порты SIMPLE_COPY:
| Тип порта | Номер | Обязательный | Описание | Метаданные |
|---|---|---|---|---|
| Input | 0 | да | Для входящего потока записей | Любые |
| Output | 0 | да | Для скопированных записей | Как у Input 0 |
| 1-n | нет | Как у Output 0 |
Пример. Копирование данных.
Нужно скопировать записи с метаданными «carID» и «mark» в три потока.
Входящие записи:
порт 0:
| carID | mark |
|---|---|
| 145 | mercedes |
| 856 | toyota |
| 245 | chevrolet |
Решение:
Для копирования в несколько потоков нужно подключить SIMPLE_COPY несколько выходных портов. Записи на всех выходных портах будут идти в одинаковом порядке.
Исходящие записи:
порт 0:
| carID | mark |
|---|---|
| 145 | mercedes |
| 856 | toyota |
| 245 | chevrolet |
порт 1:
| carID | mark |
|---|---|
| 145 | mercedes |
| 856 | toyota |
| 245 | chevrolet |
порт 2:
| carID | mark |
|---|---|
| 145 | mercedes |
| 856 | toyota |
| 245 | chevrolet |