Worker-to-Worker-Kommunikation in Sektwasser

Question

Ich denke, es ist aus dem System Diagramm impliziert, dass funkelndes Wasser Arbeiter zu Arbeiter direkte Kommunikation implementiert (ohne zurück zum Master). Kann jemand darauf hinweisen, wo der Code ist diese Funktion?

Answer 1

Sparkling Water verwendet exakt das gleiche Kommunikationsmuster wie Spark. Der Treiber startet die Berechnung und koordiniert die Arbeit unter mehreren Arbeiterknoten. Sparkling Water ist im Grunde nur Spark-Anwendung mit H2O-Knoten in jedem Spark JVM (für alle Executoren und Treiber)