查看 spark 示例代码获取 pi 值
发布时间
阅读量：
阅读量
此前便了解过利用蒙特卡洛方法通过投针实验估算圆周率PI的原理，今日完成Spark的安装后，首先需要运行其自带的一些示例程序以确认功能是否正常。由于本人主要使用Python进行编程，因此选择pyspark作为开发工具，进而前往Spark安装目录下的examples文件夹中寻找Python相关的示例代码。在该目录深处发现了一个名为pi.py的文件，查看其源代码后得知其内容如下：
import sys
from random import random
from operator import add
from pyspark import SparkContext
if __name__ == "__main__":
"""
Usage: pi [partitions]
"""
sc = SparkContext(appName="PythonPi")
partitions = int(sys.argv[1]) if len(sys.argv) > 1 else 2
n = 100000 * partitions
def f全部评论 (0)
还没有任何评论哟~