赞
踩
- # 导包
- from pyspark import SparkConf, SparkContext
- # 创建SparkConf类对象
- conf = SparkConf().setMaster("local[*]").setAppName("test_spark_app")
- # 基于SparkConf类对象创建SparkContext对象
- sc = SparkContext(conf=conf)
- # 查看PySpark的运行版本
- print(sc.version)
- # 停止SparkContext对象的运行(停止PySpark程序)
- sc.stop()
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。