Acumulatorها متغیرهایی هستند که فقط از طریق یک عملیات ارتباطی به آنها "افزوده می شوند" و بنابراین می توانند به طور موازی به طور موثر پشتیبانی شوند. می توان از آنها برای پیاده سازی شمارنده (مانند MapReduce) یا مجموع استفاده کرد. Spark به طور بومی از انباشته‌کننده‌های انواع عددی پشتیبانی می‌کند و برنامه‌نویسان می‌توانند از انواع جدید پشتیبانی کنند.
چرا از اکومولاتور استفاده می کنیم؟
آکومولاتورهای هیدرولیک در طیف گسترده ای از صنایع برای ذخیره انرژی استفاده می شود. حفظ فشار؛ ارتعاشات، ضربان ها و شوک ها را خنثی کنید. و خیلی بیشتر. ذخیره انرژی - انباشته‌کننده‌ها می‌توانند انرژی را به شکل سیال تحت فشار بپذیرند، ذخیره و آزاد کنند تا کارایی سیستم هیدرولیک شما را بهبود بخشند.
تفاوت پخش و آکومولاتور در Spark چیست؟
تفاوت اصلی بین متغیر پخش و انباشته است که در حالی که متغیر پخش فقط خواندنی است است، می توان انباشته را به آن اضافه کرد. … هر گره کارگر فقط می تواند به مقدار انباشت کننده محلی خود دسترسی داشته باشد و به آن اضافه کند، و فقط برنامه درایور می تواند به مقدار جهانی دسترسی داشته باشد.
آکومولاتور Spark چگونه کار می کند؟
Acumulatorها متغیرهایی هستند که برای جمع‌آوری اطلاعات در بین مجری‌ها استفاده می‌شوند. برای مثال، این اطلاعات می‌تواند مربوط به داده‌ها یا تشخیص API باشد.
چرا متغیر انباشته در Spark نباید توسط کارگر برای عملیات تبدیل استفاده شود؟
Acumulator خروجی اشتباهی می دهد. اگر یک کار کند اجرا می شود، Spark می تواند یک کپی فرضی از آن کار را در گره دیگری راه اندازی کند. حکم: رسیدگی نشده است. Acumulator خروجی اشتباه می دهد.
