/
dim81
/
learning-spark
Обзор
Документация
Войти
/
dim81
/
learning-spark
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
src/python/WordCount.py
13 строк
394 B
Holden Karau
Auto pep8ify the python code
06 сен 2014, 00:13
06 сен 2014, 00:13
2b7d8bd
Код
Авторство
О чём код?
import sys from pyspark import SparkContext if __name__ == "__main__": master = "local" if len(sys.argv) == 2: master = sys.argv[1] sc = SparkContext(master, "WordCount") lines = sc.parallelize(["pandas", "i like pandas"]) result = lines.flatMap(lambda x: x.split(" ")).countByValue() for key, value in result.iteritems(): print "%s %i" % (key, value)