Data Engineering

PySpark - Grootschalige verwerking

SparkSession, RDD vs DataFrame, transformations, actions, partitioning, broadcast variables, UDFs, Spark SQL, caching

20 gespreksvragen·
Senior
1

Wat is het belangrijkste startpunt voor het maken van een PySpark-applicatie?

Antwoord

SparkSession is het uniforme startpunt dat in Spark 2.0 werd geïntroduceerd. Het vervangt de oude SparkContext, SQLContext en HiveContext door één enkel object. SparkSession maakt het mogelijk om DataFrames te maken, SQL-queries uit te voeren en de Spark-applicatie centraal te configureren.

2

Wat is het fundamentele verschil tussen een RDD en een DataFrame in PySpark?

Antwoord

Een DataFrame heeft een gestructureerd schema met benoemde en getypeerde kolommen, waardoor Spark queries kan optimaliseren via Catalyst. Een RDD is een ongestructureerde gedistribueerde collectie waarbij Spark de interne datastructuur niet kent, wat mogelijke optimalisaties beperkt.

3

Wat is het verschil tussen een transformation en een action in PySpark?

Antwoord

Transformations worden lazy geëvalueerd en bouwen een uitvoeringsplan op zonder berekening te starten. Actions starten de daadwerkelijke uitvoering van het plan op het cluster en geven een resultaat terug aan de driver. Dit onderscheid stelt Spark in staat het plan vóór de uitvoering te optimaliseren.

4

Welke van de volgende operaties is een PySpark-action?

5

Hoe maak je een DataFrame van een Parquet-bestand in PySpark?

+17 gespreksvragen

Beheers Data Engineering voor je volgende gesprek

Krijg toegang tot alle vragen, flashcards, technische tests, code review-oefeningen en gespreksimulatoren.

Begin gratis