JoinEnrichment 2025.10.2.19¶
Pacote¶
org.apache.nifi | nifi-standard-nar
Descrição¶
Une registros de dois FlowFiles diferentes, sendo que um FlowFile, o “original”, contém registros arbitrários e o segundo FlowFile, o “enrichment”, contém dados adicionais que devem ser usados para enriquecer o primeiro. Consulte Detalhes adicionais para obter mais informações sobre como configurar esse processador e os diferentes casos de uso que ele pretende realizar.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Record Reader de enriquecimento |
O Record Reader para ler o FlowFile de “enriquecimento” |
Caminho do registro de inserção |
Especifica onde, no registro “original”, os campos do registro de “enriquecimento” devem ser inseridos. Observe que, se RecordPath não apontar para nenhum campo existente no registro original, o enriquecimento não será inserido. |
Estratégia de adesão |
Especifica como unir os dois FlowFiles em um único FlowFile |
Número máximo de compartimentos |
Especifica o número máximo de compartimentos que podem ser mantidos na memória em um determinado momento |
Record Reader original |
O Record Reader para ler o FlowFile “original” |
Record Writer |
O Record Writer a ser usado para gravar os resultados. Se o Record Writer estiver configurado para herdar o esquema do registro, o esquema que ele herdará será o resultado da fusão do esquema de registro “original” e do esquema de registro de “enriquecimento”. |
SQL |
The SQL SELECT statement to evaluate. Expression Language may be provided, but doing so may result in poorer performance. Because this Processor is dealing with two FlowFiles at a time, it “s also important to understand how attributes will be referenced. If both FlowFiles have an attribute with the same name but different values, the Expression Language will resolve to the value provided by the” enrichment” FlowFile. |
Tempo limite |
Especifica o tempo máximo de espera pelo segundo FlowFile depois que o primeiro chega ao processador, após o qual o primeiro FlowFile será encaminhado para a relação de “tempo limite”. |
dbf-default-precision |
Quando um valor DECIMAL/NUMBER é escrito como um tipo lógico Avro “decimal”, é necessária uma “precisão” específica que indique o número de dígitos disponíveis. Em geral, a precisão é definida pela definição do tipo de dados da coluna ou pelo padrão dos mecanismos do banco de dados. Entretanto, a precisão indefinida (0) pode ser retornada por alguns mecanismos de banco de dados. A “precisão decimal padrão” é usada ao escrever esses números de precisão indefinida. |
dbf-default-scale |
Quando um valor DECIMAL/NUMBER é escrito como um tipo lógico Avro “decimal”, é necessária uma “escala” específica que indique o número de dígitos decimais disponíveis. Em geral, a escala é determinada pela definição do tipo de dados da coluna ou pelo padrão dos mecanismos do banco de dados. No entanto, quando a precisão indefinida (0) é retornada, a escala também pode ser incerta com alguns mecanismos de banco de dados. A “escala decimal padrão” é usada ao escrever esses números indefinidos. Se um valor tiver mais casas decimais do que a escala especificada, o valor será arredondado para cima, por exemplo, 1,53 se torna 2 com escala 0 e 1,5 com escala 1. |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Se tanto os FlowFiles “original” quanto de “enriquecimento” chegarem ao processador, mas houver uma falha na junção dos registros, ambos os FlowFiles serão encaminhados para essa relação. |
joined |
O FlowFile resultante com registros unidos a partir dos FlowFiles “original” e de “enriquecimento” serão encaminhados para essa relação |
original |
Ambos os FlowFiles de entrada (“original” e “enrichment”) serão encaminhados para essa relação. Ou seja, esta é a versão “original” de ambos FlowFiles. |
timeout |
Se um dos FlowFiles de entrada (ou seja, o FlowFile “original” ou o FlowFile de “enriquecimento”) chegar a esse processador, mas o outro não chegar dentro do período de tempo limite configurado, o FlowFile que chegou será roteado para essa relação. |
Grava atributos¶
Nome |
Descrição |
|---|---|
mime.type |
Define o atributo mime.type para o tipo MIME especificado pelo Record Writer |
record.count |
O número de registros no FlowFile |