Defining a schema
Creating a defined schema helps with data quality and import performance. As mentioned during the lesson, we'll create a simple schema to read in the following columns:
- Name
- Age
- City
The Name and City columns are StringType() and the Age column is an IntegerType().
Latihan ini merupakan bagian dari kursus
Cleaning Data with PySpark
Instruksi latihan
- Import
*from thepyspark.sql.typeslibrary. - Define a new schema using the
StructTypemethod. - Define a
StructFieldforname,age, andcity. Each field should correspond to the correct datatype and not benullable.
Latihan interaktif langsung praktik
Cobalah latihan ini dengan melengkapi kode contoh ini.
# Import the pyspark.sql.types library
____
# Define a new schema using the StructType method
people_schema = ____([
# Define a StructField for each field
StructField('name', ____, False),
____('____', IntegerType(), ____)
____
])