python spark 求解最大 最小 平均
rdd=sc.parallelizeDoubles(testData); Now we’ll calculate the mean of our dataset. 1 LOGGER.info("Mean: "+rdd.mean()); There are similar methods for other statistics operation such as max, standard deviation, …etc. Every time one of this method is invoked , Spark performs the operation on the entire RDD data. If more than one operations performed, it will repeat again and again which is very inefficient. To solve this, Spark provides “StatCounter” class which executes once and provides results o...
