Construyendo una fila de un diccionario en PySpark

En este artículo, discutiremos cómo construir una fila desde el diccionario en PySpark.

Para ello, pasaremos el diccionario al método Row().

Sintaxis:

Sintaxis: Fila(dict)

Ejemplo 1: Cree una fila con un par clave-valor (Diccionario) como argumentos.

Aquí, vamos a pasar la Fila con Diccionario 

Sintaxis: Fila({‘Clave’:”valor”, ‘Clave’:”valor”,’Clave’:”valor”})

# import Row
from pyspark.sql import Row
  
# dict
dic = {'First_name':"Sravan", 
       'Last_name':"Kumar",
       'address':"hyderabad"}
  
# create a row with three values
# as dictionary.
row = Row(dic)
  
# display row
print(row)

Producción:

<Row({‘First_name’: ‘Sravan’, ‘Last_name’: ‘Kumar’, ‘address’: ‘hyderabad’})>

Ejemplo 2: programa Python para construir dos Filas con diccionario.

Sintaxis: Fila(dict, dict)

Código:

# import Row
from pyspark.sql import Row
  
dic_1 = {'First_name':"Sravan", 
         'Last_name':"Kumar",
         'address':"hyderabad"}
  
dic_2 = {'First_name':"Bobby",
         'Last_name':"Gottumukkala",
         'address':"Ponnur"}
  
# create two rows with
# three values as dictionary.
row = [Row(dic_1),
       Row(dic_2)]
# display row
print(row)

Producción:

[<Row({‘First_name’: ‘Sravan’, ‘Last_name’: ‘Kumar’, ‘address’: ‘hyderabad’})>,

 <Row({‘First_name’: ‘Bobby’, ‘Last_name’: ‘Gottumukkala’, ‘address’: ‘Ponnur’})>]