Deseamos darte la mejor información que hallamos por todo internet. Nuestro deseo es que te resulte de utilidad y si puedes aportar cualquier detalle que nos pueda ayudar a perfeccionar nuestra información hazlo con total libertad.
Ejemplo 1: mapa plano en python
rdd2=rdd.flatMap(lambda x: x.split(" "))
for element in rdd2.collect():
print(element)
Ejemplo 2: mapa plano en python
data = ["Project Gutenberg’s",
"Alice’s Adventures in Wonderland",
"Project Gutenberg’s",
"Adventures in Wonderland",
"Project Gutenberg’s"]
rdd=spark.sparkContext.parallelize(data)
for element in rdd.collect():
print(element)
Ejemplo 3: mapa plano en python
import pyspark
from pyspark.sql import SparkSession
spark = SparkSession.builder.appName('pyspark-by-examples').getOrCreate()
arrayData = [
('James',['Java','Scala'],'hair':'black','eye':'brown'),
('Michael',['Spark','Java',None],'hair':'brown','eye':None),
('Robert',['CSharp',''],'hair':'red','eye':''),
('Washington',None,None),
('Jefferson',['1','2'],)
df = spark.createDataFrame(data=arrayData, schema = ['name','knownLanguages','properties'])
from pyspark.sql.functions import explode
df2 = df.select(df.name,explode(df.knownLanguages))
df2.printSchema()
df2.show()
Ejemplo 4: mapa plano en python
from pyspark.sql import SparkSession
spark = SparkSession.builder.appName('SparkByExamples.com').getOrCreate()
data = ["Project Gutenberg’s",
"Alice’s Adventures in Wonderland",
"Project Gutenberg’s",
"Adventures in Wonderland",
"Project Gutenberg’s"]
rdd=spark.sparkContext.parallelize(data)
for element in rdd.collect():
print(element)
#Flatmap
rdd2=rdd.flatMap(lambda x: x.split(" "))
for element in rdd2.collect():
print(element)
valoraciones y reseñas
Agradecemos que desees añadir valor a nuestra información añadiendo tu veteranía en los informes.
¡Haz clic para puntuar esta entrada!
(Votos: 0 Promedio: 0)