JoinEnrichment 2025.5.31.15¶
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 |
A instrução SQL SELECT a ser avaliada. A linguagem de expressão pode ser fornecida, mas isso pode resultar em um desempenho inferior. Como esse processador está lidando com dois FlowFiles ao mesmo tempo, também é importante entender como os atributos serão referenciados. Se ambos os FlowFiles tiverem um atributo com o mesmo nome, mas com valores diferentes, a linguagem de expressão resolverá o valor fornecido pelo FlowFile de “enriquecimento”. |
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 |