1. Learn
    2. /
  2. Courses
    3. /
  3. Wprowadzenie do Spark SQL w Pythonie
Connected

Exercise

Sumy bieżące z użyciem funkcji okna w SQL

Funkcja okna działa podobnie jak funkcja agregująca, z tą różnicą, że zwraca wynik dla każdego wiersza w zbiorze danych – nie jeden wiersz na grupę.

Funkcje okna można łączyć z agregacją. Obliczanie sumy bieżącej za pomocą funkcji okna jest prostsze niż rozwiązanie oparte na złączeniach, a zapytanie może działać znacznie szybciej.

Do dyspozycji masz tabelę schedule z kolumnami train_id, station, time oraz diff_min. Kolumna diff_min zawiera czas, jaki upływa między bieżącą stacją a następną stacją na trasie.

Instructions

100 XP
  • Napisz zapytanie, które dodaje do wyników dodatkową kolumnę running_total. Kolumna running_total oblicza SUM() różnic czasu między stacjami, podanych w kolumnie diff_min.
  • Uruchom zapytanie i wyświetl wynik.