Advertisement
Guest User

Untitled

a guest
Jan 20th, 2020
109
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.39 KB | None | 0 0
  1. // Zależność pomiędzy liczbą wypadków a warunkami pogodowymi
  2. val pogoda_pom_DS = pogoda_DS.withColumnRenamed("id", "pog_id").
  3.   withColumnRenamed("nazwa", "pogoda").
  4.   select("pog_id", "pogoda")
  5. val analiza4_DS = wypadki_DS.
  6.   join(pogoda_DS, $"id_weather" === $"pog_id").
  7.   groupBy("pogoda").
  8.   agg(sum("Accidents_Count").as("liczba_wypadkow").
  9.   select("pogoda", "liczba_wypadkow")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement