Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // Zależność pomiędzy liczbą wypadków a warunkami pogodowymi
- val pogoda_pom_DS = pogoda_DS.withColumnRenamed("id", "pog_id").
- withColumnRenamed("nazwa", "pogoda").
- select("pog_id", "pogoda")
- val analiza4_DS = wypadki_DS.
- join(pogoda_DS, $"id_weather" === $"pog_id").
- groupBy("pogoda").
- agg(sum("Accidents_Count").as("liczba_wypadkow").
- select("pogoda", "liczba_wypadkow")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement