Commit80c20ed

Pedro Bernardo

committed

Added rdd/persist/PersistExample.py

1 parent652d9ff commit80c20edCopy full SHA for 80c20ed

File tree

-0

lines changed

-0

lines changed

Lines changed: 9 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,9 @@`
	`1`	`+frompysparkimportSparkContext,StorageLevel`
	`2`	`+`
	`3`	`+if__name__=="__main__":`
	`4`	`+sc=SparkContext("local","persist")`
	`5`	`+inputIntegers= [1,2,3,4,5]`
	`6`	`+integerRdd=sc.parallelize(inputIntegers)`
	`7`	`+integerRdd.persist(StorageLevel.MEMORY_ONLY)`
	`8`	`+integerRdd.reduce(lambdax,y:x*y)`
	`9`	`+integerRdd.count()`

Comments

(0)