Was ist Funkenübertragung?
Was ist Funkenübertragung?

Video: Was ist Funkenübertragung?

Video: Was ist Funkenübertragung?
Video: Hertzscher Dipol – Wie funktioniert eine Antenne? 2024, Kann
Anonim

Übertragen Variablen in Apache Funke ist ein Mechanismus für die gemeinsame Nutzung von Variablen durch Executoren, die schreibgeschützt sein sollen. Ohne übertragen Variablen Diese Variablen würden für jede Transformation und Aktion an jeden Executor gesendet, und dies kann Netzwerk-Overhead verursachen.

Ebenso fragen die Leute, wann soll ich Spark senden?

Übertragen Variablen werden meistens verwendet, wenn die Aufgaben über mehrere Stufen hinweg dieselben Daten erfordern oder wenn die Daten in deserialisierter Form zwischengespeichert werden müssen. Übertragen Variablen werden mit einer Variablen v erstellt, indem SparkContext aufgerufen wird.

Was sind Akkumulatoren und Broadcast-Variablen in Spark? Funke unterstützt zwei Arten von Shared Variablen : Broadcast-Variablen , die verwendet werden kann, um einen Wert im Speicher auf allen Knoten zwischenzuspeichern, und Akkumulatoren , welche sind Variablen die nur „addiert“werden, wie Zähler und Summen.

Was ist in diesem Zusammenhang ein Funkenspeicher?

Akkus sind Variablen, die nur durch eine assoziative Operation „hinzugefügt“werden und daher effizient parallel unterstützt werden können. Sie können verwendet werden, um Zähler (wie in MapReduce) oder Summen zu implementieren. Funke nativ unterstützt Akkumulatoren numerischer Typen, und Programmierer können Unterstützung für neue Typen hinzufügen.

Wie aktualisiere ich meine Broadcast-Variable in Spark?

  1. Verschieben Sie die Referenzdatensuche in eine forEachPartition oder forEachRdd, sodass sie sich vollständig auf den Workern befindet.
  2. Starten Sie den Spark-Kontext jedes Mal neu, wenn sich die Refdata mit einer neuen Broadcast-Variablen ändert.

Empfohlen: