始める無料で始める

フライトと目的地の空港を結合する

あなたは、グローバルな旅行会社のデータエンジニアとして採用されました。最初のタスクは、フライトデータを分析して会社の業務改善に貢献することです。ワークスペースには、フライトの詳細を含むデータセット（flights）と、目的地の空港情報を含むデータセット（airports）の2つが用意されており、どちらもすでにワークスペースで利用可能です。

目標は、これらのデータセットを組み合わせて、各フライトと目的地の空港を紐づけた統合データセットを作成することです。

この演習はコースの一部です

PySpark 入門

コースを見る

演習の手順

  • airports DataFrame を確認し、airports を flights テーブルに結合するためのキー列を特定します。
  • flights と airports DataFrame を "dest" 列で結合し、結果を flights_with_airports として保存します。
  • flights_with_airports を再度確認し、追加された新しい情報に注目します。

実践的なインタラクティブ演習

このサンプルコードを完成させて、この演習に挑戦してみましょう。

# Examine the data
airports.____()

# .withColumnRenamed() renames the "faa" column to "dest"
airports = airports.withColumnRenamed("faa", "dest")

# Join the DataFrames
flights_with_airports = ____

# Examine the new DataFrame
flights_with_airports.____
コードを編集して実行