Aggregator Transformation στην Informatica με Παράδειγμα
Τι είναι ο Μετασχηματισμός Συσσωρευτή;
Ο μετασχηματισμός συσσωρευτή είναι ένας ενεργός μετασχηματισμός που χρησιμοποιείται για την εκτέλεση συγκεντρωτικών υπολογισμών όπως άθροισμα, μέσος όρος κ.λπ.
Για παράδειγμα, εάν θέλετε να υπολογίσετε το άθροισμα των μισθών όλων των υπαλλήλων του τμήματος, μπορούμε να χρησιμοποιήσουμε το Aggregator Transformation.
Οι συγκεντρωτικές πράξεις εκτελούνται σε μια ομάδα σειρών, επομένως απαιτείται ένα προσωρινό σύμβολο κράτησης θέσης για την αποθήκευση όλων αυτών των εγγραφών και την εκτέλεση των υπολογισμών.
Για αυτό, χρησιμοποιείται η προσωρινή μνήμη aggregator. Αυτή είναι μια προσωρινή κύρια μνήμη που εκχωρείται στον μετασχηματισμό του αθροιστή για να εκτελέσει τέτοιες λειτουργίες.
Σε αυτό το παράδειγμα, θα υπολογίσουμε το άθροισμα των μισθών του τμήματος. Για αυτό, χρειαζόμαστε μια νέα στήλη για την αποθήκευση αυτού του αθροίσματος. Έτσι, πρώτα απ 'όλα, θα ετοιμάσουμε μια νέα στήλη.
Βήμα 1) Δημιουργήστε έναν νέο πίνακα στόχων βάσης δεδομένων, για παράδειγμα, πείτε "sum_sal_deptwise", χρησιμοποιώντας το παρακάτω σενάριο. Θα δείτε ότι ο νέος πίνακας στόχου βάσης δεδομένων δημιουργείται κάτω από Target φάκελο στο επόμενο βήμα.
Κάντε λήψη του παραπάνω αρχείου Create_table_sal_deptwise.txt
Βήμα 2) Δημιουργήστε μια νέα αντιστοίχιση "m_ sum_sal_deptwise".
Για να δημιουργήσουμε νέα αντιστοίχιση, χρειαζόμαστε πίνακα προέλευσης (EMP) και πίνακα προορισμού (sum_sal_deptwise) τόσο στον σχεδιαστή χαρτογράφησης για αυτό που χρειαζόμαστε
- Εισαγάγετε τον πίνακα στόχο "sum_sal_deptwise" στην αντιστοίχιση.
- Εισαγάγετε τον πίνακα προέλευσης "emp".
Βήμα 3) Στη χαρτογράφηση,
- Από το Προσδιορισμός πηγής, διαγράψτε τις στήλες empno, ename, job, mgr, hiredate & comm, αφήνοντας μόνο τις στήλες deptno και sal.
- Δημιουργήστε έναν νέο μετασχηματισμό αθροιστή χρησιμοποιώντας το μενού της εργαλειοθήκης όπως φαίνεται στο στιγμιότυπο οθόνης. Όταν κάνετε κλικ στο εικονίδιο του aggregator, θα δημιουργηθεί ένας νέος μετασχηματισμός aggregator.
Βήμα 4) Σύρετε και αποθέστε στήλες SAL & DEPTNO από το προσδιοριστικό πηγής (SQ_EMP) στον μετασχηματισμό του αθροιστή
Βήμα 5) Double κάντε κλικ στον μετασχηματισμό του αθροιστή για να ανοίξετε τις ιδιότητές του και, στη συνέχεια
- Προσθέστε μια νέα θύρα στον μετασχηματισμό
- Μετονομάστε το όνομα της θύρας σε SUM_SAL
- Αλλάξτε τον τύπο δεδομένων αυτής της νέας θύρας σε διπλάσιο
- Κάντε αυτήν τη θύρα ως θύρα εξόδου επιλέγοντας το πλαίσιο ελέγχου της θύρας εξόδου.
- Κάντε κλικ στην επιλογή έκφρασης
Βήμα 6) Στο παράθυρο έκφρασης
- Προσθέστε έκφραση- sum (SAL), πρέπει να γράψετε αυτήν την έκφραση.
- Επιλέξτε το κουμπί Ok, αυτό θα επαναφέρει το παράθυρο μετασχηματισμού επεξεργασίας.
Βήμα 7) Στο παράθυρο επεξεργασίας μετασχηματισμού, επιλέξτε την επιλογή «GroupBy» σημειώνοντας το πλαίσιο ελέγχου στη στήλη deptno και κάντε κλικ στο Ok (επιλέγοντας group by έναντι του deptno, δίνουμε εντολή στην Informatica να ομαδοποιήσει τους μισθούς ανά deptno)
Βήμα 8) Συνδέστε τις στήλες deptno και sum_sal από τον μετασχηματισμό του aggregator στον πίνακα προορισμού
Τώρα αποθηκεύστε το χαρτης και εκτελέστε το αφού δημιουργήσετε μια νέα συνεδρία για αυτήν την αντιστοίχιση. Ο πίνακας-στόχος θα περιέχει το άθροισμα των μισθών του τμήματος. Με αυτόν τον τρόπο, μπορούμε να χρησιμοποιήσουμε μετασχηματισμό συσσωρευτή για να υπολογίσουμε τα συγκεντρωτικά αποτελέσματα.