python
from dpark import DparkContext
def word_count(file_path):
dpark = DparkContext()
data = dpark.textFile(file_path)
word_counts = data.flatMap(lambda line: line.split()).map(lambda word: (word, 1)).reduceByKey(lambda a, b: a + b)
result = word_counts.collect()
print(result)
if __name__ == "__main__":
word_count("file.txt")
