在Spark中，共享變量是指在集群中的所有任務之間共享的可變變量。Spark支持兩種類型的共享變量：廣播變量和累加器。
# 在Python中創建廣播變量
broadcast_var = sc.broadcast([1, 2, 3])
# 在任務中使用廣播變量
def my_func(value):
for num in broadcast_var.value:
print(num * value)
rdd.map(my_func).collect()
# 在Python中創建累加器
accum = sc.accumulator(0)
# 在任務中使用累加器
def my_func(value):
accum.add(value)
return value
rdd.map(my_func).collect()
print(accum.value)
共享變量的使用要小心，因為它們可能會導致并發訪問和狀態不一致的問題，特別是在多個任務同時修改一個共享變量的情況下。因此，建議仔細考慮共享變量的使用場景，確保線程安全和可靠性。
