从批次创建 ArrayStreams

从批次创建 ArrayStreams

用法

basic_array_stream(batches, schema = NULL, validate = TRUE)

参数

batches

一个由 nanoarrow_array 对象或可以通过 as_nanoarrow_array() 强制转换的对象组成的 list()。

schema

一个 nanoarrow_schema 或 NULL，用于根据第一个 schema 进行猜测。

validate

使用 FALSE 跳过验证步骤（即，如果您知道数组是有效的）。

返回值

一个 nanoarrow_array_stream

示例

(stream <- basic_array_stream(list(data.frame(a = 1, b = 2))))
#> <nanoarrow_array_stream struct<a: double, b: double>>
#>  $ get_schema:function ()  
#>  $ get_next  :function (schema = x$get_schema(), validate = TRUE)  
#>  $ release   :function ()  
as.data.frame(stream$get_next())
#>   a b
#> 1 1 2
stream$get_next()
#> NULL