Τι είναι η εκπομπή σπινθήρα;
Τι είναι η εκπομπή σπινθήρα;

Βίντεο: Τι είναι η εκπομπή σπινθήρα;

Βίντεο: Τι είναι η εκπομπή σπινθήρα;
Βίντεο: Πώς αναζωογονείται ο πνευματικός μας σπινθήρας, α΄ μέρος – ESOTERIC HEALING 2024, Νοέμβριος
Anonim

Αναμετάδοση μεταβλητές στο Apache Σπίθα είναι ένας μηχανισμός για την κοινή χρήση μεταβλητών μεταξύ των εκτελεστών που προορίζονται να είναι μόνο για ανάγνωση. Χωρίς αναμετάδοση μεταβλητές αυτές οι μεταβλητές θα αποστέλλονται σε κάθε εκτελεστή για κάθε μετασχηματισμό και ενέργεια, και αυτό μπορεί να προκαλέσει επιβάρυνση δικτύου.

Ομοίως, οι άνθρωποι ρωτούν, πότε πρέπει να εκπέμπω σπινθήρα;

Αναμετάδοση Οι μεταβλητές χρησιμοποιούνται ως επί το πλείστον όταν οι εργασίες σε πολλά στάδια απαιτούν τα ίδια δεδομένα ή όταν απαιτείται η αποθήκευση στην προσωρινή μνήμη των δεδομένων στην αποσειριοποιημένη μορφή. Αναμετάδοση Οι μεταβλητές δημιουργούνται χρησιμοποιώντας μια μεταβλητή v καλώντας το SparkContext.

Επίσης, τι είναι οι συσσωρευτές και οι μεταβλητές εκπομπής στο spark; Σπίθα υποστηρίζει δύο τύπους κοινόχρηστων μεταβλητές : μεταβλητές εκπομπής , το οποίο μπορεί να χρησιμοποιηθεί για την προσωρινή αποθήκευση μιας τιμής στη μνήμη σε όλους τους κόμβους και συσσωρευτές , τα οποία είναι μεταβλητές που μόνο «προστίθενται», όπως μετρητές και αθροίσματα.

Λαμβάνοντας υπόψη αυτό, τι είναι ο συσσωρευτής σπινθήρα;

Συσσωρευτές είναι μεταβλητές που «προστίθενται» μόνο μέσω μιας συσχετιστικής λειτουργίας και επομένως μπορούν να υποστηριχθούν αποτελεσματικά παράλληλα. Μπορούν να χρησιμοποιηθούν για την υλοποίηση μετρητών (όπως στο MapReduce) ή αθροισμάτων. Σπίθα εγγενώς υποστηρίζει συσσωρευτές αριθμητικών τύπων και οι προγραμματιστές μπορούν να προσθέσουν υποστήριξη για νέους τύπους.

Πώς μπορώ να ενημερώσω τη μεταβλητή εκπομπής μου στο spark;

  1. Μετακινήστε την αναζήτηση δεδομένων αναφοράς σε ένα forEachPartition ή forEachRdd, έτσι ώστε να ανήκει εξ ολοκλήρου στους εργαζόμενους.
  2. Επανεκκινήστε το Spark Context κάθε φορά που αλλάζουν τα refdata, με μια νέα μεταβλητή Broadcast.

Συνιστάται: