抽樣。
減少
減少抽樣的元素使用指定的交換和關聯二元運算符。目前降低本地分區。
例子
> > >從操作符進口添加> > >sc。並行化([1,2,3,4,5])。減少(添加)15> > >sc。並行化((2為_在範圍(10)))。地圖(λx:1)。緩存()。減少(添加)10> > >sc。並行化([])。減少(添加)回溯(最近的電話):…ValueError:不能減少()空抽樣
以前的
pyspark.RDD.randomSplit
下一個
pyspark.RDD.reduceByKey