帮我写一个Spark实时词频统计

好的，下面是一个简单的Spark Streaming实时词频统计程序：

from pyspark import SparkConf, SparkContext
from pyspark.streaming import StreamingContext

# 创建Spark配置对象
conf = SparkConf().setAppName("StreamingWordCount").setMaster("local[*]")

# 创建SparkContext对象
sc = SparkContext(conf=conf)

# 创建StreamingContext对象
ssc = StreamingContext(sc, 1)

# 监听socket流
lines = ssc.socketTextStream("localhost", 9999)

# 对每一行进行分词
words = lines.flatMap(lambda line: line.split())

# 计算每个单词出现的次数
word_counts = words.map(lambda word: (word, 1)).reduceByKey(lambda x, y: x + y)

# 输出结果
word_counts.pprint()

# 启动StreamingContext
ssc.start()

# 等待程序终止
ssc.awaitTermination()

这个程序的流程如下：

1. 创建一个 SparkConf 对象，指定应用程序的名称和运行模式（本地模式）。
2. 创建一个 SparkContext 对象，用于连接到 Spark 集群。
3. 创建一个 StreamingContext 对象，指定微批处理的时间间隔为1秒。
4. 监听一个TCP socket流，返回一个 DStream 对象。
5. 使用 `flatMap` 方法对每一行进行分词，将文本转换成单词列表。
6. 使用 `map` 方法将每个单词转换成一个键值对，键为单词，值为 1。
7. 使用 `reduceByKey` 方法统计每个单词出现的次数。
8. 使用 `pprint` 方法将结果输出到控制台。
9. 启动 StreamingContext。
10. 使用 `awaitTermination` 方法等待程序终止。

这个程序可以通过`nc`命令模拟一个TCP socket流：

nc -lk 9999

然后在终端输入一些文本，程序就会实时统计每个单词出现的次数并输出到控制台。注意要在程序运行之前先启动`nc`命令。