Skip to content

Instantly share code, notes, and snippets.

@ppillay
Last active June 16, 2017 04:22
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ppillay/4cfe146a27d684bafd96db693ba43349 to your computer and use it in GitHub Desktop.
Save ppillay/4cfe146a27d684bafd96db693ba43349 to your computer and use it in GitHub Desktop.
val resultDF = df.filter("delay > 0")
.groupBy("origin", "dest")
.avg("delay")
.sort(col("avg(delay)").desc)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment