RecordSinkServiceLookup

Описание

Предоставляет RecordSinkService, который можно использовать для динамического выбора другого RecordSinkService. Для работы этого сервиса требуется атрибут с именем 'record.sink.name'. Если этот атрибут отсутствует, будет выброшено исключение. Значение 'record.sink.name' будет использоваться для выбора RecordSinkService, зарегистрированного с этим именем. Это позволит определить и зарегистрировать несколько RecordSinkService, а затем динамически выбирать их во время выполнения, помечая FlowFile соответствующим атрибутом 'record.sink.name'. Обратите внимание, что этот сервис контроллера не предназначен для использования в задачах отчетности, которые используют экземпляры RecordSinkService, такие как QueryNiFiReportingTask.

Теги

record, sink, lookup

Свойства

Название	Описание
Отсутствуют