一.需要環(huán)境

1.python
2.pyspark
3.spark

二.代碼

from pyspark import SparkConf, SparkContext
conf = SparkConf().setMaster("local[*]").setAppName("First_App")  #配置環(huán)境
sc = SparkContext(conf=conf) #加載環(huán)境
textFile = sc.textFile('example.txt') #讀取文件
count = textFile.countByValue()  #統(tǒng)計(jì)單詞頻數(shù)
print(count)