Introduktion till PySpark DataFrames

Introduktion till PySpark

Benjamin Schmidt

Data Engineer

Om DataFrames

  • DataFrames: Tabellformat (rader/kolumner)
  • Stöder SQL-liknande operationer
  • Jämförbart med en Pandas DataFrame eller en SQL-tabell
  • Strukturerad data

Dataframes

Introduktion till PySpark

Skapa DataFrames från fillagringar

# Create a DataFrame from CSV
census_df = spark.read.csv('path/to/census.csv', header=True, inferSchema=True)
Introduktion till PySpark

Skriv ut DataFramen

# Show the first 5 rows of the DataFrame
census_df.show()


   age  education.num marital.status         occupation income
0   90              9        Widowed                  ?  <=50K
1   82              9        Widowed    Exec-managerial  <=50K
2   66             10        Widowed                  ?  <=50K
3   54              4       Divorced  Machine-op-inspct  <=50K
4   41             10      Separated     Prof-specialty  <=50K
Introduktion till PySpark

Skriv ut DataFramens schema

# Show the schema
census_df.printSchema()

Output: root |-- age: integer (nullable = true) |-- education.num: integer (nullable = true) |-- marital.status: string (nullable = true) |-- occupation: string (nullable = true) |-- income: string (nullable = true)
Introduktion till PySpark

Grundläggande analys med PySpark DataFrames

# .count() will return the total row numbers in the DataFrame
row_count = census_df.count()
print(f'Number of rows: {row_count}')
# groupby() allows the use of sql-like aggregations
census_df.groupBy('gender').agg({'salary_usd': 'avg'}).show()

Andra aggregatfunktioner:

  • sum()
  • min()
  • max()
Introduktion till PySpark

Viktiga funktioner för PySpark-analys

  • .select(): Väljer specifika kolumner från DataFramen
  • .filter(): Filtrerar rader baserat på villkor
  • .groupBy(): Grupperar rader efter en eller flera kolumner
  • .agg(): Tillämpar aggregatfunktioner på grupperad data
Introduktion till PySpark

Exempel på viktiga funktioner

# Using filter and select, we can narrow down our DataFrame
filtered_census_df = census_df.filter(df['age'] > 50).select('age', 'occupation')
filtered_census_df.show()

Output +---+------------------+ |age| occupation | +---+------------------+ | 90| ?| | 82| Exec-managerial| | 66| ?| | 54| Machine-op-inspct| +---+------------------+
Introduktion till PySpark

Nu kör vi en övning!

Introduktion till PySpark

Preparing Video For Download...