RevolutionAnalytics / dplyr-spark

spark backend for dplyr
48 stars 18 forks source link

compute fails #10

Closed piccolbo closed 9 years ago

piccolbo commented 9 years ago

flights_SparkSQL %>% mutate(gain = arr_delay - dep_delay) %>% compute %>% mutate(gain_per_hour = gain / (air_time / 60))