Как определить глобальную переменную scala в Spark, которая будет доступна всем работникам?
В программе Spark я ХОЧУ Определить переменную типа неизменяемой карты, к которой все рабочие программы будут обращаться синхронно, что я могу сделать? Должен ли я определить объект Scala?
Не только неизменяемая карта, что, если я хочу переменную, которая может совместно использоваться и может обновляться синхронно? Например, «изменяемая карта», «var Int» или «var String» или некоторые другие? Что я могу сделать? В порядке ли переменная объекта scala? Например:
Object SparkObj{
var x:Int
var y:String
}
Поддерживает ли x и y драйвер вместо рабочего и используется ли он всеми рабочими?Есть ли у x и y только одна копия вместо нескольких?
Является ли обновление до x и y синхронным?