Discussion :

[purplebamboo]

Bonjour,
j'ai un problème lorsque j'effectue une auto-jointure sur un champ (qui n'est pas une clé ). Tout se passe bien sauf pour la dernière ligne qui passe en rejet? Si j'ajoute une nouvelle ligne n+1, la ligne n qui ne passait pas passe; et la ligne n+1 ne passe pas...

Quelqu'un aurait-il déja eu ce problème? Est-ce que je passe à coté d'une grosse erreur sans m'en apercevoir?

Merci d'avance

(pb: chq ligne possede un numero id et un numero id2. Il peut y avoir plusieurs id2 pour un id. Le but étant de mettre à jour un champ "test" à 1 qd il y a plusieurs numero id2 pour un id.
Je fais dc une auto-jointure sur le champ id et un filtre !a.id2.equals(b.id2) dans le tmap)

[purplebamboo]

Personne n'a eu ce pb?

[DevNico]

Bonjour,

Quel est le message d'erreur que tu obtiens ?
Tu pourrais nous mettre une copie d'écran de ton job ainsi que du paramétrage du tMap ?

Sinon par rapport à ta problématique, est-ce qu'il ne serait pas plus simple et plus performant d'utiliser juste un tAggregateRow qui conterait le nombre de lignes par valeur du champ id, de stocker le résultat dans un fichier sous la forme (id, flag (0/1)), puis d'utiliser ce fichier en lookup pour mettre à jour tes données ?

Merci,
Nicolas

[purplebamboo]

Bonjour,
en fait, je n'ai aucun message d'erreur. Je m'aperçoit seulement que la dernière ligne passe en rejet.

Voici le schema que j'utilise.


(il y a une jointure interne sur id.)

Sinon, oui il sera effectivement plus rapide d'ajouter un tAggregaterow sur le champ id. je vais tester cette solution de suite et voir si cela marche mieux.

Merci pour ta réponse rapide.

[purplebamboo]

Je viens de tester en mettant un tAggregaterow mais cela ne marche pas comme je le voudrais. En effet, si on effectue l'aggregation avant la jointure, on ne peut pas savoir quels id possèdent plusieurs id2. Je suis donc obligé de faire une autojointure (il me semble).

Voici le schema du tmap:



(ici le champ test est mis à 2 pour les id présentant plusieurs id2)

[DevNico]

Je ne suis pas certain que tu aies bien paramétré ton tAggregaterow ?

A priori, en entrée du composant, tu ne dois avoir que les champs id et id2. Groupé par id, et en sortie je dirais qu'il faut appliquer la fonction compter(distinct) sur le champ id2.

Tu as donc en sortie un flux avec 1 ligne par valeur du champ id, et le nombre de id2 différents auquel chaque id est lié.

C'est ce flux que tu utilises ensuite en lookup.

Nicolas

[purplebamboo]

Ok ca marche!!!
je renvoyais le champ id2 tel quel. Du coup qd je faisais row1.id2!=row2.id2, il y avait toujours une ligne non mise à jour pour chaque paquet d'id présentant des id2 différents.
merci pour ton aide