RevolutionAnalytics / dplyr-spark

spark backend for dplyr
48 stars 18 forks source link

filter on simultaneous aggregation fails #8

Closed piccolbo closed 9 years ago

piccolbo commented 9 years ago

bestworst <- daily %>% select(flight, arr_delay) %>% filter(arr_delay == min(arr_delay) || arr_delay == max(arr_delay))

ranked <- daily %>% select(arr_delay) %>% mutate(rank = rank(desc(arr_delay)))

piccolbo commented 9 years ago

fixed as part of #27