1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
#' @format NULL
spec_arrow <- c(
spec_arrow_send_query_arrow,
spec_arrow_fetch_arrow,
spec_arrow_fetch_arrow_chunk,
spec_arrow_get_query_arrow,
spec_arrow_read_table_arrow,
spec_arrow_write_table_arrow,
spec_arrow_create_table_arrow,
spec_arrow_append_table_arrow,
spec_arrow_bind,
spec_arrow_roundtrip,
#
NULL
)
utils::globalVariables("select")
stream_frame <- function(..., .select = NULL) {
data <- data.frame(..., stringsAsFactors = FALSE, check.names = FALSE)
as_is <- map_lgl(data, inherits, "AsIs")
data[as_is] <- map(data[as_is], function(.x) {
class(.x) <- setdiff(class(.x), "AsIs")
.x
})
if (!is.null(.select)) {
data <- data[.select]
}
out <- nanoarrow::as_nanoarrow_array_stream(data)
out
}
|
