ForkRecord

Описание

Этот процессор позволяет пользователю разделить запись на несколько записей. Пользователь должен указать по крайней мере один путь записи как динамическое свойство, указывающее на поле типа ARRAY, содержащее объекты RECORD. Процессор принимает два режима: 'split' и 'extract'. В обоих режимах создается одна запись на каждый элемент, содержащийся в указанном массиве. В режиме 'split' каждая созданная запись сохранит ту же схему, что и входная, но массив будет содержать только один элемент. В режиме 'extract' элемент массива должен быть типа записи и будет созданной записью. Кроме того, в режиме 'extract' можно указать, должны ли каждая созданная запись содержать все поля родительских записей от корневого уровня до извлеченной записи. Это предполагает, что поля для добавления в запись определены в схеме службы контроллера Writer для записей. См. примеры в дополнительной документации этого процессора.

Теги

fork, record, content, array, stream, event

Свойства

Название	Описание
Record Reader	Указывает службу контроллера для чтения входящих данных
Record Writer	Указывает службу контроллера для записи данных
Mode	Указывает режим разветвления процессора
Include Parent Fields	Этот параметр действителен только в режиме «извлечение». Если установлено значение true, все поля от корневого уровня до заданного массива будут добавлены в качестве полей каждого элемента массива для разветвления.

Взаимосвязи

• failure: В случае, если потоковый файл генерирует ошибку во время операции разветвления, он будет перенаправлен на эту связь
• original: Исходные файлы Flow будут отнесены к этой связи
• fork: Файлы Flow, содержащие разветвленные записи, будут отнесены к этой связи