Если вам нужен точный ответ, вам сначала нужно отсканировать полный набор данных, чтобы подсчитать пропущенные значения:
library(dplyr)
df <- copy_to(sc, tibble(
id = 1:4, Price = c(NA, 3.20, NA, 42),
Product = c("p1", "p2", "p3", "p4"),
Status = c(NA, "foo", "bar", NA)))
null_counts <- df %>%
summarise_all(funs(sum(as.numeric(is.na(.)), na.rm=TRUE))) %>%
collect()
null_counts
# A tibble: 1 x 4
id Price Product Status
<dbl> <dbl> <dbl> <dbl>
1 0 2 0 2
определить, в каких столбцах отсутствует число, равное нулю:
cols_without_nulls <- null_counts %>%
select_if(funs(. == 0)) %>%
colnames()
cols_without_nulls
[1] "id" "Product"
и используйте их для выбора
df %>% select(one_of(cols_without_nulls))
# Source: spark<?> [?? x 2]
id Product
<int> <chr>
1 1 p1
2 2 p2
3 3 p3
4 4 p4
Существует более короткий вариант:
df %>% select_if(funs(sum(as.numeric(is.na(.)), na.rm=TRUE) == 0))
Applying predicate on the first 100 rows
# Source: spark<?> [?? x 2]
id Product
<int> <chr>
1 1 p1
2 2 p2
3 3 p3
4 4 p4
, но, как вы видите, он будет только пробоватьданные.