Aggregatortransformatie in Informatica met voorbeeld

Wat is aggregatortransformatie?

Aggregatortransformatie is een actieve transformatie die wordt gebruikt om aggregatieberekeningen uit te voeren, zoals som, gemiddelde, enz.

Als u bijvoorbeeld de som van de salarissen van alle werknemersafdelingen wilt berekenen wise, kunnen we de Aggregator-transformatie gebruiken.

De aggregatiebewerkingen worden uitgevoerd over een groep rijen, dus er is een tijdelijke tijdelijke aanduiding nodig om al deze records op te slaan en de berekeningen uit te voeren.

Aggregatortransformatie in Informatica met voorbeeld

Hiervoor wordt aggregator-cachegeheugen gebruikt. Dit is een tijdelijk hoofdgeheugen dat wordt toegewezen aan de aggregatortransformatie om dergelijke bewerkingen uit te voeren.

In dit voorbeeld berekenen we de som van de salarissen van de afdeling wise. Hiervoor hebben we een nieuwe kolom nodig om dit bedrag op te slaan. Dus allereerst zullen we een nieuwe kolom voorbereiden.

Stap 1 – Maak een nieuwe databasedoeltabel, zeg bijvoorbeeld “sum_sal_deptwise”, met behulp van het onderstaande script. U zult zien dat de nieuwe databasedoeltabel in de volgende stap onder Doelmap wordt gemaakt.

Download het bovenstaande Create_table_sal_deptwise.txt-bestand

Stap 2 - Maak een nieuwe toewijzing “m_sum_sal_deptwise'.

Om een ​​nieuwe mapping te maken, hebben we de brontabel (EMP) en de doeltabel (sum_sal_deptwise) beide in de mapping-ontwerper, daarvoor hebben we dat nodig

  1. Importeer de doeltabel “sum_sal_deptwise” in de kaart.
  2. Importeer de brontabel “emp”.

Aggregatortransformatie in Informatica met voorbeeld

Stap 3 – Op de kaart,

  1. Van de Bronkwalificatie, verwijder de kolommen empno, ename, job, mgr, hireate & comm zodat alleen de kolommen deptno en sal overblijven.
  2. Maak een nieuwe aggregatortransformatie met behulp van de toolbox menu zoals weergegeven in de schermafdruk. Wanneer u op het aggregatorpictogram klikt, wordt er een nieuwe aggregatortransformatie gemaakt.

Aggregatortransformatie in Informatica met voorbeeld

Stap 4 – SAL- en DEPTNO-kolommen slepen en neerzetten van bronkwalificatie (SQ_EMP) naar de aggregatortransformatie

Aggregatortransformatie in Informatica met voorbeeld

Stap 5 - Double klik op de aggregatortransformatie om de eigenschappen ervan te openen, en vervolgens

  1. Voeg een nieuwe poort toe aan de transformatie
  2. Hernoem de poortnaam naar SUM_SAL
  3. Wijzig het gegevenstype van deze nieuwe poort in double
  4. Maak deze poort als uitvoerpoort door het vinkje te selecterenbox van de uitgangspoort.
  5. Klik op de expressieoptie

Aggregatortransformatie in Informatica met voorbeeld

Stap 6 – In het expressievenster

  1. Voeg expression-sum(SAL) toe, je moet deze expressie schrijven.
  2. Selecteer de knop OK, hierdoor wordt het venster voor het bewerken van de transformatie teruggebracht.

Aggregatortransformatie in Informatica met voorbeeld

Stap 7 – Selecteer in het bewerkingstransformatievenster de optie “GroupBy” door het vinkje te plaatsen box tegen de deptno-kolom en klik op Ok (door groeperen op tegen de deptno te selecteren, instrueren we Informatica om salarissen te groeperen op deptno)

Aggregatortransformatie in Informatica met voorbeeld

Stap 8 – Koppel de kolommen deptno en sum_sal van de aggregatortransformatie naar de doeltabel

Aggregatortransformatie in Informatica met voorbeeld

Bewaar nu de in kaart brengen en voer het uit nadat u een nieuwe sessie voor deze mapping hebt gemaakt. De doeltabel zou de som van de salarissen van de afdeling bevatten wise. Op deze manier kunnen we aggregatortransformatie gebruiken om geaggregeerde resultaten te berekenen.