概率与期望
结论1 设 x x x 为离散随机变量,且 x ∈ N x\in\mathbb N x∈N,则 E ( x ) ∑ i 1 ∞ i ⋅ P ( x i ) ∑ i 1 ∞ P ( x ≥ i ) E(x) \sum \limits_{i 1}^{\infty}iP(x i) \sum \limits_{i 1}^{\infty}P(x \ge i) E(x)i1∑∞i⋅…
spark08 这就是广播变量,每个executor中复用一份数据,在driver端将数据广播出去,在executor端使用 val bd sc.broadcast(iparr)val proRDD accRDD.map(t>{ val province binarySeach(t,bd.value) (province,1)}) 广播变量的内部机制…