Added rdd/reduce/ReduceExample.py

Pedro Bernardo · Pedro Bernardo · commit 8838805d14bb · 2017-09-27T18:10:05.000+02:00
diff --git a/rdd/reduce/ReduceExample.py b/rdd/reduce/ReduceExample.py
@@ -0,0 +1,8 @@
+from pyspark import SparkContext
+
+if __name__ == "__main__":
+    sc = SparkContext("local", "reduce")
+    inputIntegers = [1, 2, 3, 4, 5]
+    integerRdd = sc.parallelize(inputIntegers)
+    product = integerRdd.reduce(lambda x, y: x * y)
+    print("product is :{}".format(product))
