Spalten bearbeiten
Die Federal Aviation Administration (FAA) betrachtet einen Flug als „verspätet", wenn er 15 Minuten oder mehr nach der planmäßigen Zeit ankommt.
Der nächste Schritt in der Aufbereitung der Flugdaten hat zwei Teile:
- die Umrechnung der Entfernungseinheiten, wobei die Spalte
miledurch eine Spaltekmersetzt wird; und - das Erstellen einer booleschen Spalte, die angibt, ob ein Flug verspätet war oder nicht.
Diese Übung ist Teil des Kurses
<Kurs>Maschinelles Lernen mit PySpark</Kurs>Übungsanweisungen
- Importiere eine Funktion, mit der du eine Zahl auf eine bestimmte Anzahl von Dezimalstellen runden kannst.
- Leite eine neue Spalte
kmaus der Spaltemileab und runde auf null Dezimalstellen. Eine Meile entspricht 1,60934 km. - Entferne die Spalte
mile. - Erstelle eine Spalte
labelmit dem Wert 1, wenn die Verspätung 15 Minuten oder mehr betrug, sonst 0. Überlege dir die logische Bedingung gut.
Interaktive praktische Übung
Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.
# Import the required function
from pyspark.sql.functions import ____
# Convert 'mile' to 'km' and drop 'mile' column (1 mile is equivalent to 1.60934 km)
flights_km = flights.____('km', ____(____ * ____, 0)) \
.____('mile')
# Create 'label' column indicating whether flight delayed (1) or not (0)
flights_km = flights_km.____('label', (____).cast('integer'))
# Check first five records
flights_km.show(5)