Le composant tMap est configuré pour effectuer une jointure sur les données relatives aux films et aux cinéastes.
Une fois les données chargées dans le Job, vous devez configurer le composant tMap pour qu'il effectue une jointure sur ces données, afin de produire la sortie attendue.
Procédure
-
Double-cliquez sur le tMap pour ouvrir son éditeur Map Editor.
-
Déposez les colonnes movieID, title, releaseYear et url de gauche dans les tables de sortie.
Du côté de l'entrée (gauche) du Map Editor, chacune des deux tables représente l'un des flux d'entrée. La table supérieure représente le flux d'entrée principal et la table inférieure représente le flux de référence (Lookup).
Du côté de la sortie (droite), les deux tables représentent les flux de sortie nommés out1 et reject lorsque vous avez lié le tMap au tFileOutputDelimited dans Déposer et relier des composants.
-
Du côté de l'entrée, déposez la colonne directorID de la table du flux principal à la colonne Expr.key de la ligne ID, dans la table du flux de référence.
Ainsi, la clé de jointure entre le flux principal et le flux de référence est définie.
-
Déposez la colonne directorID du flux principal à la table reject de sortie, puis déposez la colonne Name de la table de référence à la table out1.
La configuration des deux étapes précédentes décrit comment les colonnes des données d’entrée sont mappées aux colonnes du flux de sortie.
Dans la vue Schema editor, dans la partie inférieure de l'éditeur, vous pouvez voir que les schémas des deux côtés ont été automatiquement renseignés.
-
Dans la table de sortie out1, cliquez sur le bouton
pour afficher le champ d'expression de filtre.
-
Saisissez
row1.directorId != null
Cela permet au tMap d'écrire en sortie uniquement les enregistrements de films dans lesquels le champ directorID n'est pas vide. Un enregistrement ayant un champ directorID vide ne sera pas écrit en sortie.
-
Dans la table de sortie reject, cliquez sur le bouton
pour ouvrir les paramètres.
-
Pour l'option Catch Output Reject, sélectionnez true pour écrire en sortie les enregistrements ayant un champ directorID vide dans le flux reject.
-
Cliquez sur Apply puis sur OK afin de valider ces modifications. Acceptez la propagation proposée par la boîte de dialogue.