Accumulator — переменная-счётчик, агрегаруемая на драйвере из updates на executors (метрики, число отфильтрованных строк). Для отладки/метрик, не для бизнес-логики ветвлений.
Разбор
- Обновления внутри трансформаций могут считаться >1 при retry — осторожно.
- Надёжнее считать метрики в агрегатах DataFrame.
- Именованные accumulators видны в UI.
- Только add, без чтения на executor.
Итог
Accumulator — диагностика/счётчики; для данных используйте агрегации DataFrame.