EDUCBA

Home Software Development Software Development Tutorials Python Tutorial PySpark SQL Types

PySpark SQL Types

Updated April 11, 2023

PySpark SQL Types

 

 

Introduction to PySpark SQL Types

PySpark SQL TYPES is a class in the PySpark model that is used to define all the data types in the PySpark data model that is used. The data frame, when created, has a data type that is defined which takes care of the type of data needed while creation. The SQL Types can be considered as the base class for defining these data Types in the PySpark data model.
A package pyspark.sql.types.DataType is defined in PySpark that takes care of all the data type models needed to be defined and used. There are various data types such as String Type, Numeric Type, Byte Type that are defined in this package which can be used for defining the data model over PySpark. In this article, we will try to analyze the various ways of using the PYSPARK SQL TYPE operation PySpark.

Start Your Free Software Development Course

Web development, programming languages, Software testing & others

Syntax 

The syntax is as follows:

from pyspark.sql.types import ArrayType
from pyspark.sql.types import IntegerType
from pyspark.sql.types import StringType
from pyspark.sql.types import MapType

These are the import Type of SQL that is used in PySpark SQL Types.

Screenshot:

PySpark SQL Types 1

Working of SQL Types in PySpark

  • The SQL Types in PySpark defines the type of value that needs to be stored in the PySpark data model. Each Data Type is defined by some size range that defines the element size that can be stored.
  • The import function pyspark.sql.types provide with the Type of data that needs to be imported and defines the data type regarding this. Some of the data types are Binary data type, Numeric Data Type.
  • Once the type of data is defined, it makes the analysis of data easier, and certain data type-related operations can be easily done with regard to that.
  • Every time a variable is created or every time when columns are created, a data type is needed for this column and a variable that is done by SQL types. We can also convert these data types once done based on our requirement and can function the data model properly.

Let’s check the creation and working with some coding examples.

Examples

Let us see some examples. Some types are a subclass of data types.

Array Type:

This SQL type can be achieved by importing the ArrayType from the package

from pyspark.sql.types import ArrayType

There are some methods also that defines the type of elements in the ArrayType as:

at = ArrayType(IntegerType(),False)
print(at.jsonValue())
print(at.simpleString())
print(at.typeName())

This ArrayType has some method that is defined for the SQL Types.

Screenshot:

PySpark SQL Types 2
StringType()

This data type is used to represent StringValues.

s = StringType()
s

This defines the type as String type. All the string type methods are defined over this SQL Type.

Screenshot:

PySpark SQL Types 3

Maptype:

It represents the key-value pair in the Data frame. A key and value pair is set to define the MAP Type.

from pyspark.sql.types import MapType
m = MapType(StringType(), IntegerType())
print(m.keyType)
print(m.valueType)

Screenshot:

Maptype

Date Type

This is used to represent Data in the Data Frame of a PySpark. All the data type methods can be done once converting it into DateType.

from pyspark.sql.types import DateType
d = DateType()
d

Screenshot:

Data Type

Timestamp

This represents the data frame of the type Time Stamp.

The timestamp type() is used to get the timestamp of SQL type.

This is of the format:- yyyy-mm-dd HH:mm: ss. ssss

from pyspark.sql.types import TimestampType
t = TimestampType()
t

Screenshot:

PySpark SQL Types 4

There is a method by which a SQL TYPES can be created to Data Frame in PySpark.

Note:

1. PySpark SQL TYPES are the data types needed in the PySpark data model.

2. It has a package that imports all the types of data needed.

3. It has a limit range for the type of data needed.

4. It is used to create a data frame with a specific type.

5. It has the base class Data Type that contains all the base class SQL types elements.

Conclusion

The various methods used showed how it eases the pattern for data analysis and a cost-efficient model for the same.
We also saw the internal working and the advantages of SQL TYPES in PySpark Data Frame and its usage for various programming purposes. Also, the syntax and examples helped us to understand much precisely the function.

Recommended Articles

We hope that this EDUCBA information on “PySpark SQL Types” was beneficial to you. You can view EDUCBA’s recommended articles for more information.

  1. PySpark Left Join
  2. PySpark count distinct
  3. PySpark Logistic Regression
  4. PySpark Lag
quiz