Introduction In this tutorial, we want to add columns to a PySpark DataFrame. In order to do this, we use the the withColumn() method of PySpark. Import Libraries First, we import the following python modules: from pyspark.sql import SparkSession from pyspark.sql.functions import lit, col, sum, when from...
Introduction In this tutorial, we want to select specific columns from a PySpark DataFrame. In order to do this, we use the select() method of PySpark in different variants. Import Libraries First, we import the following python modules: from pyspark.sql import SparkSession from pyspark.sql.functions import col Create...
Introduction In this tutorial, we want to rename a PySpark DataFrame column. In order to do this, we use the the withColumnRenamed() method of PySpark. Import Libraries First, we import the following python modules: from pyspark.sql import SparkSession Create SparkSession Before we can work with Pyspark, we need to...
Introduction In this tutorial, we want to select data from a table by using a SQL Statement. The result should not contain duplicate rows. In order to do this, we use the SELECT Statement with the DISTINCT Clause. We have already created the table student with the following data: Example...
Introduction In this tutorial, we want to filter specific rows from a Pandas DataFrame based on specific conditions. In order to do this, we use DataFrame conditions with logical operators, the loc() method and the query() method of Pandas. Import Libraries First, we import the following python modules: import pandas...
Introduction In this tutorial, we want to convert a PySpark DataFrame into a Pandas DataFrame with a specific schema. In order to do this, we use the the toPandas() method of PySpark. Import Libraries First, we import the following python modules: from pyspark.sql import SparkSession Create SparkSession Before we...
Introduction In this tutorial, we want to convert a Pandas DataFrame into a PySpark DataFrame with a specific schema. In order to do this, we use the the createDataFrame() function of PySpark. Import Libraries First, we import the following python modules: import pandas as pd from pyspark.sql import...
Introduction In this tutorial, we want to select data from a table by using a SQL Statement. In order to do this, we use the SELECT Statement. We have already created the table student with the following data: Example 1 - SELECT specific columns We want to select the columns...
Introduction In this tutorial, we want to delete specific rows from a table by using a SQL Statement. In order to do this, we use the DELETE Statement. We have already created the table student with the following data: Example 1 We want to delete all rows where the name...
