Ejemplo: paralelizar en el ejemplo de pyspark
----------------------------------------foreach.py---------------------------------------
from pyspark import SparkContext
sc = SparkContext("local", "ForEach app")
words = sc.parallelize (
["scala",
"java",
"hadoop",
"spark",
"akka",
"spark vs hadoop",
"pyspark",
"pyspark and spark"]
)
def f(x): print(x)
fore = words.foreach(f)
----------------------------------------foreach.py---------------------------------------
Output:
scala
java
hadoop
spark
akka
spark vs hadoop
pyspark
pyspark and spark¡Haz clic para puntuar esta entrada!
(Votos: 0 Promedio: 0)