ForkRecord 2025.5.31.15¶

Pacote¶

org.apache.nifi | nifi-standard-nar

Descrição¶

Esse processador permite que o usuário bifurque um registro em vários registros. O usuário deve especificar pelo menos um caminho de registro, como uma propriedade dinâmica, apontando para um campo do tipo ARRAY contendo objetos RECORD. O processador aceita dois modos: “dividir” (split) e “extrair” (extract). Em ambos os modos, é gerado um registro por elemento contido na matriz designada. No modo “dividir”, cada registro gerado preservará o mesmo esquema fornecido na entrada, mas a matriz conterá apenas um elemento. No modo “extrair”, o elemento da matriz deve ser do tipo registro e será o registro gerado. Além disso, no modo “extrair”, é possível especificar se cada registro gerado deve conter todos os campos dos registros pai, desde o nível raiz até o registro extraído. Isso pressupõe que os campos a serem adicionados ao registro estejam definidos no esquema do serviço de controlador do Record Writer. Veja exemplos na documentação de detalhes adicionais desse processador.

Tags¶

array, content, event, fork, record, stream

Requisito de entrada¶

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
fork-mode	Especifica o modo de bifurcação do processador
include-parent-fields	Esse parâmetro só é válido no modo “extrair”. Se definido como verdadeiro, todos os campos do nível raiz para a matriz fornecida serão adicionados como campos de cada elemento da matriz a ser bifurcada.
record-reader	Especifica o Controller Service a ser usado para ler os dados recebidos
record-writer	Especifica o Controller Service a ser usado para gravar os registros

Relações¶

Nome	Descrição
failure	Caso o FlowFile gere um erro durante a operação de bifurcação, ele será encaminhado para essa relação
fork	Os FlowFiles com os registros bifurcados serão encaminhados para essa relação
original	Os FlowFiles originais serão encaminhados para essa relação

Grava atributos¶

Nome	Descrição
record.count	O FlowFile gerado terá um atributo “record.count” indicando o número de registros que foram gravados no FlowFile.
mime.type	O tipo MIME indicado pelo Record Writer
<Atributos do Record Writer>	Qualquer atributo que o Record Writer configurado retornar será adicionado ao FlowFile.