ForkEnrichment 2025.5.31.15

Pacote

org.apache.nifi | nifi-standard-nar

Descrição

Usado em conjunto com o processador JoinEnrichment, esse processador é responsável por adicionar os atributos necessários para que o processador JoinEnrichment execute sua função. Cada FlowFile de entrada será clonado. O FlowFile original terá os atributos apropriados adicionados e, em seguida, será transferido para a relação “original”. O clone terá os atributos apropriados adicionados e, em seguida, será encaminhado para a relação de “enrichment”. Consulte a documentação do processador JoinEnrichment (e especialmente seus Detalhes adicionais) para obter mais informações sobre como esses processadores funcionam juntos e como executar tarefas de enriquecimento no NiFi usando esses processadores.

Tags

enrich, fork, join, record

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Relações

Nome

Descrição

enrichment

Um clone do FlowFile de entrada será encaminhado para essa relação, após adicionar os atributos apropriados.

original

O FlowFile de entrada será encaminhado para essa relação, após adicionar os atributos apropriados.

Grava atributos

Nome

Descrição

enrichment.group.id

O ID de grupo a ser usado para correlacionar o FlowFile de “original” com o FlowFile de “enrichment”.

enrichment.role

A função a ser usada para enriquecimento. Isso será ORIGINAL ou ENRICHMENT.

Consulte também