JoinEnrichment 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Description¶
Réunit des enregistrements provenant de deux FlowFiles différents, dont l’un, FlowFile original, contient des enregistrements arbitraires et l’autre, FlowFile d’enrichissement, contient des données supplémentaires à utiliser pour enrichir le premier. Voir Détails supplémentaires pour plus d’informations sur la configuration de ce processeur et les différents cas d’utilisation qu’il vise à accomplir.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Record Reader d’enrichissement |
Le Record Reader pour la lecture du FlowFile d’enrichissement |
Chemin d’enregistrement d’insertion |
Spécifie l’emplacement dans l’enregistrement « original » où les champs d’enregistrement « enrichissement » doivent être insérés. Notez que si le RecordPath ne renvoie à aucun champ existant dans l’enregistrement original, l’enrichissement ne sera pas inséré. |
Stratégie d’adhésion |
Indique comment réunir les deux FlowFiles en un seul FlowFile |
Nombre maximal de bacs |
Spécifie le nombre maximum de bacs qui peuvent être conservés en mémoire à un moment donné |
Record Reader original |
Le Record Reader pour lire le FlowFile “original” |
Record Writer |
Le Record Writer à utiliser pour écrire les résultats. Si le Record Writer est configuré pour hériter du schéma de l’enregistrement, le schéma dont il héritera sera le résultat de la fusion du schéma de l’enregistrement « riginal » et du schéma de l’enregistrement d’enrichissement. |
SQL |
L’instruction SQL SELECT à évaluer. La langue d’expression peut être fournie, mais cela peut entraîner une baisse des performances. Étant donné que ce processeur traite deux FlowFiles à la fois, il est également important de comprendre comment les attributs seront référencés. Si les deux FlowFiles ont un attribut portant le même nom mais des valeurs différentes, la langue d’expression se résoudra à la valeur fournie par le FlowFile d’enrichissement. |
Expiration |
Indique la durée maximale d’attente du second FlowFile lorsque le premier arrive au processeur, après délai d’expiration le premier FlowFile sera routé vers la relation “timeout’. |
dbf-default-precision |
Lorsqu’une valeur DECIMAL/NUMBER est écrite sous la forme d’un type logique Avro décimal, une précision spécifique indiquant le nombre de chiffres disponibles est exigée. En général, la précision est définie par la définition du type de données de la colonne ou par les moteurs de base de données par défaut. Toutefois, certains moteurs de base de données peuvent renvoyer une précision non définie (0). La précision décimale par défaut est utilisée pour écrire des nombres dont la précision n’est pas définie. |
dbf-default-scale |
Lorsqu’une valeur DECIMAL/NUMBER est écrite sous la forme d’un type logique Avro décimal, une échelle spécifique indiquant le nombre de chiffres décimaux disponibles est exigée. En général, l’échelle est définie par la définition du type de données de la colonne ou par les moteurs de base de données par défaut. Toutefois, lorsque la précision renvoyée est indéfinie (0), l’échelle peut également être incertaine avec certains moteurs de base de données. L’échelle décimale par défaut est utilisée lors de l’écriture de ces nombres non définis. Si une valeur comporte plus de décimales que l’échelle spécifiée, la valeur sera arrondie à l’unité supérieure, par exemple 1,53 devient 2 avec l’échelle 0, et 1,5 avec l’échelle 1. |
Relations¶
Nom |
Description |
|---|---|
failure |
Si les FlowFiles de type « original » et « enrichissement » arrivent tous deux au processeur mais qu’il y a eu un échec dans l’association des enregistrements, ces deux FlowFiles seront routés vers cette relation. |
joined |
Le FlowFile qui en résulte et dont les enregistrements ont été réunis à partir des FlowFiles original et enrichissement sera routé vers cette relation |
original |
Les deux FlowFiles entrants (« original » et « enrichissement ») seront routés vers cette relation. Il s’agit donc de la version « originale » de ces deux FlowFiles. |
timeout |
Si l’un des FlowFiles entrants (c’est-à-dire le FlowFile « original » ou le FlowFile « enrichissement ») arrive à ce processeur mais que l’autre n’arrive pas dans le délai d’expiration configuré, le FlowFile qui est arrivé est routé vers cette relation. |
Écrit les attributs¶
Nom |
Description |
|---|---|
mime.type |
Définit l’attribut mime.type sur le type MIME spécifié par le Record Writer |
record.count |
Le nombre d’enregistrements dans le FlowFile |