Mikä on kipinälähetys?
Mikä on kipinälähetys?

Video: Mikä on kipinälähetys?

Video: Mikä on kipinälähetys?
Video: Suuri Työ | Kun Tuli Syttyy - Porvoon Kipinä 2024, Marraskuu
Anonim

Lähettää muuttujat Apachessa Kipinä on mekanismi, jolla jaetaan muuttujat vain luku -käyttöisiksi tarkoitettujen suorittajien kesken. Ilman lähettää muuttujat, nämä muuttujat toimitettaisiin kullekin suorittajalle jokaista muunnosa ja toimintoa varten, ja tämä voi aiheuttaa verkon ylimääräisiä kustannuksia.

Samoin ihmiset kysyvät, milloin minun pitäisi lähettää kipinä?

Lähettää muuttujia käytetään enimmäkseen silloin, kun useiden vaiheiden tehtävät vaativat samoja tietoja tai kun vaaditaan tietojen tallentamista välimuistiin deserialisoidussa muodossa. Lähettää muuttujat luodaan käyttämällä muuttujaa v kutsumalla SparkContext.

Mitä ovat myös akut ja lähetysmuuttujat kipinässä? Kipinä tukee kahta tyyppiä jaettua muuttujia : lähetysmuuttujat , jota voidaan käyttää arvon tallentamiseen kaikkien solmujen muistiin, ja akut , mitkä ovat muuttujia joihin vain "lisätään", kuten laskurit ja summat.

Tämän huomioon ottaen mikä on kipinäakku?

Akut ovat muuttujia, jotka "lisätään" vain assosiatiivisen toiminnon kautta ja joita voidaan siksi tukea tehokkaasti rinnakkain. Niitä voidaan käyttää laskurien (kuten MapReducessa) tai summien toteuttamiseen. Kipinä natiivisti tukee akut numeerisia tyyppejä, ja ohjelmoijat voivat lisätä tukea uusille tyypeille.

Kuinka päivitän lähetysmuuttujani kipinässä?

  1. Siirrä viitetietojen haku forEachPartition- tai forEachRdd-kohtaan niin, että se jää kokonaan työntekijöille.
  2. Käynnistä Spark Context uudelleen aina, kun refdata muuttuu, uudella lähetysmuuttujalla.

Suositeltava: