FilesExpand file tree

 master

/

ReduceExample.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

11 lines (8 loc) · 360 Bytes

 master

/

ReduceExample.py

Copy path

Top

File metadata and controls

• Code
• Blame

11 lines (8 loc) · 360 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

from pyspark import SparkContext, SparkConf

if __name__ == "__main__":

conf = SparkConf().setAppName("reduce").setMaster("local[*]")

sc = SparkContext(conf = conf)

inputIntegers = [1, 2, 3, 4, 5]

integerRdd = sc.parallelize(inputIntegers)

product = integerRdd.reduce(lambda x, y: x * y)

print("product is :{}".format(product))